winterbaume-osis

Amazon OpenSearch Ingestion (OSIS) service implementation for winterbaume.

Coverage

Metric	Value
Service	OpenSearch Ingestion
AWS model	osis
Protocol	restJson1
winterbaume coverage	10/22 operations (45.5%)
stubs (routed, returns empty/default)	0/22 operations (0.0%)
moto coverage	13/22 operations (59.1%)
floci coverage	0/22 operations (0.0%)
kumo coverage	0/22 operations (0.0%)
Coverage report date	2026-05-13

Server-mode usage

Start winterbaume-server and point the AWS CLI at it:

cargo run -p winterbaume-server -- --host 127.0.0.1 --port 5555

export AWS_ENDPOINT_URL=http://localhost:5555
aws osis list-pipelines

Current Network Resource Stub Semantics

OSIS currently exposes VPC option shapes but does not persist detailed networking state.

• Pipeline views include an optional vpc_options JSON slot, and current snapshot construction sets it to None.
• Pipeline endpoints and service VPC endpoint shapes exist in the model, but implemented state does not create EC2 VPC endpoints or ENIs.
• VPC endpoint service names and endpoint ownership are therefore not backed by cross-service networking state.
• The implementation does not consult winterbaume-ec2 state for these identifiers, so it does not check that referenced VPCs, subnets, security groups, VPC endpoints, network interfaces, or load balancers exist, belong to the same VPC, or are in a usable lifecycle state.

Example

use aws_sdk_osis::config::BehaviorVersion;
use winterbaume_core::MockAws;
use winterbaume_osis::OsisService;

#[tokio::main]
async fn main() {
    let mock = MockAws::builder().with_service(OsisService::new()).build();

    let config = aws_config::defaults(BehaviorVersion::latest())
        .http_client(mock.http_client())
        .credentials_provider(mock.credentials_provider())
        .region(aws_sdk_osis::config::Region::new("us-east-1"))
        .load()
        .await;

    let client = aws_sdk_osis::Client::new(&config);

    let resp = client
        .list_pipelines()
        .send()
        .await
        .expect("list_pipelines should succeed");
    println!("OpenSearch Ingestion pipelines: {}", resp.pipelines().len());
}

Implemented APIs (10)

• CreatePipeline
• DeletePipeline
• GetPipeline
• ListPipelines
• ListTagsForResource
• StartPipeline
• StopPipeline
• TagResource
• UntagResource
• UpdatePipeline

Not yet implemented APIs (12)

• CreatePipelineEndpoint
• DeletePipelineEndpoint
• DeleteResourcePolicy (implemented by moto)
• GetPipelineBlueprint
• GetPipelineChangeProgress
• GetResourcePolicy (implemented by moto)
• ListPipelineBlueprints
• ListPipelineEndpointConnections
• ListPipelineEndpoints
• PutResourcePolicy (implemented by moto)
• RevokePipelineEndpointConnections
• ValidatePipeline