func buildStream()

in out_writeapi.go [279:298]

• 17 lines of code
• 2 McCabe index (conditional complexity)

func buildStream(ctx context.Context, config **outputConfig, streamIndex int) error {
	currManagedStream, err := getWriter((*config).client, ctx, (*config).currProjectID,
		managedwriter.WithType((*config).streamType),
		managedwriter.WithDestinationTable((*config).tableRef),
		// Use the descriptor proto when creating the new managed stream
		managedwriter.WithSchemaDescriptor((*config).schemaDesc),
		managedwriter.EnableWriteRetries((*config).enableRetry),
		managedwriter.WithMaxInflightBytes((*config).maxQueueBytes),
		managedwriter.WithMaxInflightRequests((*config).maxQueueRequests),
		managedwriter.WithDefaultMissingValueInterpretation(storagepb.AppendRowsRequest_DEFAULT_VALUE),
		managedwriter.WithTraceID("FluentBit"),
	)

	streamSlice := *(*config).managedStreamSlice

	if err == nil {
		(streamSlice)[streamIndex].managedstream = currManagedStream
	}
	return err
}