Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func UnwrapManagement ¶
func UnwrapManagement(r *service.Resources) bundle.NewManagement
UnwrapManagement a public *service.Resources type into an internal bundle.NewManagement type. This solution will eventually be phased out as it is only used for migrating components.
func UnwrapOwnedInput ¶
func UnwrapOwnedInput(o *service.OwnedInput) input.Streamed
UnwrapOwnedInput attempts to unwrap a public owned component into an internal variant. This is useful in cases where we're migrating internal components to use the public configuration APIs but aren't quite ready to move the full implementation yet.
Types ¶
type UnwrapInternalBatchProcessor ¶
type UnwrapInternalBatchProcessor struct {
// contains filtered or unexported fields
}
UnwrapInternalBatchProcessor is a no-op implementation of an internal component that allows a public/service environment to unwrap it straight into the needed format during construction. This is useful in cases where we're migrating internal components to use the public configuration APIs but aren't quite ready to move the full implementation yet.
func NewUnwrapInternalBatchProcessor ¶
func NewUnwrapInternalBatchProcessor(s processor.V1) *UnwrapInternalBatchProcessor
NewUnwrapInternalBatchProcessor returns wraps an internal component implementation.
func (*UnwrapInternalBatchProcessor) Close ¶
func (u *UnwrapInternalBatchProcessor) Close(ctx context.Context) error
Close does nothing, use Unwrap instead.
func (*UnwrapInternalBatchProcessor) ProcessBatch ¶
func (u *UnwrapInternalBatchProcessor) ProcessBatch(ctx context.Context, b service.MessageBatch) ([]service.MessageBatch, error)
ProcessBatch does nothing, use Unwrap instead.
func (*UnwrapInternalBatchProcessor) Unwrap ¶
func (u *UnwrapInternalBatchProcessor) Unwrap() processor.V1
Unwrap in order to obtain the underlying Streamed implementation.
type UnwrapInternalInput ¶
type UnwrapInternalInput struct {
// contains filtered or unexported fields
}
UnwrapInternalInput is a no-op implementation of an internal component that allows a public/service environment to unwrap it straight into the needed format during construction. This is useful in cases where we're migrating internal components to use the public configuration APIs but aren't quite ready to move the full implementation yet.
func NewUnwrapInternalInput ¶
func NewUnwrapInternalInput(s input.Streamed) *UnwrapInternalInput
NewUnwrapInternalInput returns wraps an internal component implementation.
func (*UnwrapInternalInput) Close ¶
func (u *UnwrapInternalInput) Close(ctx context.Context) error
Close does nothing, use Unwrap instead.
func (*UnwrapInternalInput) Connect ¶
func (u *UnwrapInternalInput) Connect(ctx context.Context) error
Connect does nothing, use Unwrap instead.
func (*UnwrapInternalInput) ReadBatch ¶
func (u *UnwrapInternalInput) ReadBatch(ctx context.Context) (service.MessageBatch, service.AckFunc, error)
ReadBatch does nothing, use Unwrap instead.
func (*UnwrapInternalInput) Unwrap ¶
func (u *UnwrapInternalInput) Unwrap() input.Streamed
Unwrap in order to obtain the underlying Streamed implementation.
type UnwrapInternalOutput ¶
type UnwrapInternalOutput struct {
// contains filtered or unexported fields
}
UnwrapInternalOutput is a no-op implementation of an internal component that allows a public/service environment to unwrap it straight into the needed format during construction. This is useful in cases where we're migrating internal components to use the public configuration APIs but aren't quite ready to move the full implementation yet.
func NewUnwrapInternalOutput ¶
func NewUnwrapInternalOutput(s output.Streamed) *UnwrapInternalOutput
NewUnwrapInternalOutput returns wraps an internal component implementation.
func (*UnwrapInternalOutput) Close ¶
func (u *UnwrapInternalOutput) Close(ctx context.Context) error
Close does nothing, use Unwrap instead.
func (*UnwrapInternalOutput) Connect ¶
func (u *UnwrapInternalOutput) Connect(ctx context.Context) error
Connect does nothing, use Unwrap instead.
func (*UnwrapInternalOutput) Unwrap ¶
func (u *UnwrapInternalOutput) Unwrap() output.Streamed
Unwrap in order to obtain the underlying Streamed implementation.
func (*UnwrapInternalOutput) WriteBatch ¶
func (u *UnwrapInternalOutput) WriteBatch(ctx context.Context, b service.MessageBatch) error
WriteBatch does nothing, use Unwrap instead.
Source Files