pubsub

package
v1.154.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 15, 2026 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BigQueryConfig_FromProto added in v1.154.0 

func BigQueryConfig_FromProto(mapCtx *direct.MapContext, in *pb.BigQueryConfig) *krm.BigQueryConfig

func BigQueryConfig_ToProto added in v1.154.0 

func BigQueryConfig_ToProto(mapCtx *direct.MapContext, in *krm.BigQueryConfig) *pb.BigQueryConfig

func CloudStorageConfigAvroConfig_FromProto added in v1.154.0 

func CloudStorageConfigAvroConfig_FromProto(mapCtx *direct.MapContext, in *pb.CloudStorageConfig_AvroConfig) *krm.CloudStorageConfigAvroConfig

func CloudStorageConfigAvroConfig_ToProto added in v1.154.0 

func CloudStorageConfigAvroConfig_ToProto(mapCtx *direct.MapContext, in *krm.CloudStorageConfigAvroConfig) *pb.CloudStorageConfig_AvroConfig

func CloudStorageConfig_FromProto added in v1.154.0 

func CloudStorageConfig_FromProto(mapCtx *direct.MapContext, in *pb.CloudStorageConfig) *krm.CloudStorageConfig

func CloudStorageConfig_ToProto added in v1.154.0 

func CloudStorageConfig_ToProto(mapCtx *direct.MapContext, in *krm.CloudStorageConfig) *pb.CloudStorageConfig

func DeadLetterPolicy_FromProto added in v1.154.0 

func DeadLetterPolicy_FromProto(mapCtx *direct.MapContext, in *pb.DeadLetterPolicy) *krm.DeadLetterPolicy

func DeadLetterPolicy_ToProto added in v1.154.0 

func DeadLetterPolicy_ToProto(mapCtx *direct.MapContext, in *krm.DeadLetterPolicy) *pb.DeadLetterPolicy

func ExpirationPolicy_FromProto added in v1.154.0 

func ExpirationPolicy_FromProto(mapCtx *direct.MapContext, in *pb.ExpirationPolicy) *krm.ExpirationPolicy

func ExpirationPolicy_ToProto added in v1.154.0 

func ExpirationPolicy_ToProto(mapCtx *direct.MapContext, in *krm.ExpirationPolicy) *pb.ExpirationPolicy

func MessageStoragePolicy_FromProto added in v1.153.0 

func MessageStoragePolicy_FromProto(mapCtx *direct.MapContext, in *pb.MessageStoragePolicy) *krm.MessageStoragePolicy

func MessageStoragePolicy_ToProto added in v1.153.0 

func MessageStoragePolicy_ToProto(mapCtx *direct.MapContext, in *krm.MessageStoragePolicy) *pb.MessageStoragePolicy

func NewSchemaModel added in v1.153.0 

func NewSchemaModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewSnapshotModel added in v1.130.2 

func NewSnapshotModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewSubscriptionModel added in v1.154.0 

func NewSubscriptionModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func NewTopicModel added in v1.153.0 

func NewTopicModel(ctx context.Context, config *config.ControllerConfig) (directbase.Model, error)

func PubSubSchemaSpec_FromProto added in v1.153.0 

func PubSubSchemaSpec_FromProto(mapCtx *direct.MapContext, in *pb.Schema) *krm.PubSubSchemaSpec

found existing non-generated mapping function "ExpirationPolicy_ToProto", skipping 

func ExpirationPolicy_ToProto(mapCtx *direct.MapContext, in *krm.ExpirationPolicy) *pb.ExpirationPolicy {
	if in == nil {
		return nil
	}
	out := &pb.ExpirationPolicy{}
	// MISSING: TTL
	// (near miss): "TTL" vs "Ttl"
	return out
}

func PubSubSchemaSpec_ToProto added in v1.153.0 

func PubSubSchemaSpec_ToProto(mapCtx *direct.MapContext, in *krm.PubSubSchemaSpec) *pb.Schema

func PubSubSnapshotObservedState_FromProto added in v1.135.0 

func PubSubSnapshotObservedState_FromProto(mapCtx *direct.MapContext, in *pb.Snapshot) *krm.PubSubSnapshotObservedState

func PubSubSnapshotObservedState_ToProto added in v1.135.0 

func PubSubSnapshotObservedState_ToProto(mapCtx *direct.MapContext, in *krm.PubSubSnapshotObservedState) *pb.Snapshot

func PubSubSnapshotSpec_FromProto 

func PubSubSnapshotSpec_FromProto(mapCtx *direct.MapContext, in *pb.Snapshot) *krm.PubSubSnapshotSpec

func PubSubSnapshotSpec_ToProto 

func PubSubSnapshotSpec_ToProto(mapCtx *direct.MapContext, in *krm.PubSubSnapshotSpec) *pb.Snapshot

func PubSubSubscriptionSpec_FromProto added in v1.154.0 

func PubSubSubscriptionSpec_FromProto(mapCtx *direct.MapContext, in *pb.Subscription) *krm.PubSubSubscriptionSpec

found existing non-generated mapping function "PubSubSnapshotSpec_ToProto", skipping 

func PubSubSnapshotSpec_ToProto(mapCtx *direct.MapContext, in *krm.PubSubSnapshotSpec) *pb.Snapshot {
	if in == nil {
		return nil
	}
	out := &pb.Snapshot{}
	// MISSING: Name
	if in.TopicRef != nil {
		out.Topic = in.TopicRef.External
	}
	out.Labels = in.Labels
	return out
}

func PubSubSubscriptionSpec_ToProto added in v1.154.0 

func PubSubSubscriptionSpec_ToProto(mapCtx *direct.MapContext, in *krm.PubSubSubscriptionSpec) *pb.Subscription

func PubSubTopicSpec_FromProto added in v1.153.0 

func PubSubTopicSpec_FromProto(mapCtx *direct.MapContext, in *pb.Topic) *krm.PubSubTopicSpec

func PubSubTopicSpec_ToProto added in v1.153.0 

func PubSubTopicSpec_ToProto(mapCtx *direct.MapContext, in *krm.PubSubTopicSpec) *pb.Topic

func PushConfigNoWrapper_FromProto added in v1.154.0 

func PushConfigNoWrapper_FromProto(mapCtx *direct.MapContext, in *pb.PushConfig_NoWrapper) *krm.PushConfigNoWrapper

found existing non-generated mapping function "PushConfig_ToProto", skipping 

func PushConfig_ToProto(mapCtx *direct.MapContext, in *krm.PushConfig) *pb.PushConfig {
	if in == nil {
		return nil
	}
	out := &pb.PushConfig{}
	out.PushEndpoint = direct.ValueOf(in.PushEndpoint)
	out.Attributes = in.Attributes
	// MISSING: OIDCToken
	// (near miss): "OIDCToken" vs "OidcToken"
	// MISSING: PubsubWrapper
	if oneof := PushConfigNoWrapper_ToProto(mapCtx, in.NoWrapper); oneof != nil {
		out.Wrapper = &pb.PushConfig_NoWrapper_{NoWrapper: oneof}
	}
	return out
}

func PushConfigNoWrapper_ToProto added in v1.154.0 

func PushConfigNoWrapper_ToProto(mapCtx *direct.MapContext, in *krm.PushConfigNoWrapper) *pb.PushConfig_NoWrapper

func PushConfigOidcToken_FromProto added in v1.154.0 

func PushConfigOidcToken_FromProto(mapCtx *direct.MapContext, in *pb.PushConfig_OidcToken) *krm.PushConfigOidcToken

func PushConfigOidcToken_ToProto added in v1.154.0 

func PushConfigOidcToken_ToProto(mapCtx *direct.MapContext, in *krm.PushConfigOidcToken) *pb.PushConfig_OidcToken

func PushConfig_FromProto added in v1.154.0 

func PushConfig_FromProto(mapCtx *direct.MapContext, in *pb.PushConfig) *krm.PushConfig

func PushConfig_ToProto added in v1.154.0 

func PushConfig_ToProto(mapCtx *direct.MapContext, in *krm.PushConfig) *pb.PushConfig

func RetryPolicy_FromProto added in v1.154.0 

func RetryPolicy_FromProto(mapCtx *direct.MapContext, in *pb.RetryPolicy) *krm.RetryPolicy

func RetryPolicy_ToProto added in v1.154.0 

func RetryPolicy_ToProto(mapCtx *direct.MapContext, in *krm.RetryPolicy) *pb.RetryPolicy

func SchemaSettings_FromProto added in v1.153.0 

func SchemaSettings_FromProto(mapCtx *direct.MapContext, in *pb.SchemaSettings) *krm.SchemaSettings

func SchemaSettings_ToProto added in v1.153.0 

func SchemaSettings_ToProto(mapCtx *direct.MapContext, in *krm.SchemaSettings) *pb.SchemaSettings

Types

type SchemaModel added in v1.153.0 

type SchemaModel struct {
	// contains filtered or unexported fields
}

func (*SchemaModel) AdapterForObject added in v1.153.0 

func (m *SchemaModel) AdapterForObject(ctx context.Context, op *directbase.AdapterForObjectOperation) (directbase.Adapter, error)

func (*SchemaModel) AdapterForURL added in v1.153.0 

func (m *SchemaModel) AdapterForURL(ctx context.Context, url string) (directbase.Adapter, error)

type SnapshotModel added in v1.130.2 

type SnapshotModel struct {
	// contains filtered or unexported fields
}

func (*SnapshotModel) AdapterForObject added in v1.130.2 

func (m *SnapshotModel) AdapterForObject(ctx context.Context, op *directbase.AdapterForObjectOperation) (directbase.Adapter, error)

func (*SnapshotModel) AdapterForURL added in v1.130.2 

func (m *SnapshotModel) AdapterForURL(ctx context.Context, url string) (directbase.Adapter, error)

type SubscriptionModel added in v1.154.0 

type SubscriptionModel struct {
	// contains filtered or unexported fields
}

func (*SubscriptionModel) AdapterForObject added in v1.154.0 

func (m *SubscriptionModel) AdapterForObject(ctx context.Context, op *directbase.AdapterForObjectOperation) (directbase.Adapter, error)

func (*SubscriptionModel) AdapterForURL added in v1.154.0 

func (m *SubscriptionModel) AdapterForURL(ctx context.Context, url string) (directbase.Adapter, error)

type TopicModel added in v1.153.0 

type TopicModel struct {
	// contains filtered or unexported fields
}

func (*TopicModel) AdapterForObject added in v1.153.0 

func (m *TopicModel) AdapterForObject(ctx context.Context, op *directbase.AdapterForObjectOperation) (directbase.Adapter, error)

func (*TopicModel) AdapterForURL added in v1.153.0 

func (m *TopicModel) AdapterForURL(ctx context.Context, url string) (directbase.Adapter, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.