imit_pubsub

package
v0.0.0-...-2efa5ab Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2022 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ImitPublisherServer 

type ImitPublisherServer struct {
	pubsub.UnimplementedPublisherServer
	// contains filtered or unexported fields
}

func (*ImitPublisherServer) CreateTopic 

func (imit *ImitPublisherServer) CreateTopic(P0 context.Context, P1 *pubsub.Topic) (*pubsub.Topic, error)

CreateTopic Imitation

func (*ImitPublisherServer) DeleteTopic 

func (imit *ImitPublisherServer) DeleteTopic(P0 context.Context, P1 *pubsub.DeleteTopicRequest) (*emptypb.Empty, error)

DeleteTopic Imitation

func (*ImitPublisherServer) DetachSubscription 

func (imit *ImitPublisherServer) DetachSubscription(P0 context.Context, P1 *pubsub.DetachSubscriptionRequest) (*pubsub.DetachSubscriptionResponse, error)

DetachSubscription Imitation

func (*ImitPublisherServer) EnqueueCreateTopicMock 

func (imit *ImitPublisherServer) EnqueueCreateTopicMock(m func(P0 context.Context, P1 *pubsub.Topic) (*pubsub.Topic, error))

CreateTopic Enqueue Mock

func (*ImitPublisherServer) EnqueueCreateTopicMocks 

func (imit *ImitPublisherServer) EnqueueCreateTopicMocks(ms []func(P0 context.Context, P1 *pubsub.Topic) (*pubsub.Topic, error))

CreateTopic Enqueue Mocks

func (*ImitPublisherServer) EnqueueDeleteTopicMock 

func (imit *ImitPublisherServer) EnqueueDeleteTopicMock(m func(P0 context.Context, P1 *pubsub.DeleteTopicRequest) (*emptypb.Empty, error))

DeleteTopic Enqueue Mock

func (*ImitPublisherServer) EnqueueDeleteTopicMocks 

func (imit *ImitPublisherServer) EnqueueDeleteTopicMocks(ms []func(P0 context.Context, P1 *pubsub.DeleteTopicRequest) (*emptypb.Empty, error))

DeleteTopic Enqueue Mocks

func (*ImitPublisherServer) EnqueueDetachSubscriptionMock 

func (imit *ImitPublisherServer) EnqueueDetachSubscriptionMock(m func(P0 context.Context, P1 *pubsub.DetachSubscriptionRequest) (*pubsub.DetachSubscriptionResponse, error))

DetachSubscription Enqueue Mock

func (*ImitPublisherServer) EnqueueDetachSubscriptionMocks 

func (imit *ImitPublisherServer) EnqueueDetachSubscriptionMocks(ms []func(P0 context.Context, P1 *pubsub.DetachSubscriptionRequest) (*pubsub.DetachSubscriptionResponse, error))

DetachSubscription Enqueue Mocks

func (*ImitPublisherServer) EnqueueGetTopicMock 

func (imit *ImitPublisherServer) EnqueueGetTopicMock(m func(P0 context.Context, P1 *pubsub.GetTopicRequest) (*pubsub.Topic, error))

GetTopic Enqueue Mock

func (*ImitPublisherServer) EnqueueGetTopicMocks 

func (imit *ImitPublisherServer) EnqueueGetTopicMocks(ms []func(P0 context.Context, P1 *pubsub.GetTopicRequest) (*pubsub.Topic, error))

GetTopic Enqueue Mocks

func (*ImitPublisherServer) EnqueueListTopicSnapshotsMock 

func (imit *ImitPublisherServer) EnqueueListTopicSnapshotsMock(m func(P0 context.Context, P1 *pubsub.ListTopicSnapshotsRequest) (*pubsub.ListTopicSnapshotsResponse, error))

ListTopicSnapshots Enqueue Mock

func (*ImitPublisherServer) EnqueueListTopicSnapshotsMocks 

func (imit *ImitPublisherServer) EnqueueListTopicSnapshotsMocks(ms []func(P0 context.Context, P1 *pubsub.ListTopicSnapshotsRequest) (*pubsub.ListTopicSnapshotsResponse, error))

ListTopicSnapshots Enqueue Mocks

func (*ImitPublisherServer) EnqueueListTopicSubscriptionsMock 

func (imit *ImitPublisherServer) EnqueueListTopicSubscriptionsMock(m func(P0 context.Context, P1 *pubsub.ListTopicSubscriptionsRequest) (*pubsub.ListTopicSubscriptionsResponse, error))

ListTopicSubscriptions Enqueue Mock

func (*ImitPublisherServer) EnqueueListTopicSubscriptionsMocks 

func (imit *ImitPublisherServer) EnqueueListTopicSubscriptionsMocks(ms []func(P0 context.Context, P1 *pubsub.ListTopicSubscriptionsRequest) (*pubsub.ListTopicSubscriptionsResponse, error))

ListTopicSubscriptions Enqueue Mocks

func (*ImitPublisherServer) EnqueueListTopicsMock 

func (imit *ImitPublisherServer) EnqueueListTopicsMock(m func(P0 context.Context, P1 *pubsub.ListTopicsRequest) (*pubsub.ListTopicsResponse, error))

ListTopics Enqueue Mock

func (*ImitPublisherServer) EnqueueListTopicsMocks 

func (imit *ImitPublisherServer) EnqueueListTopicsMocks(ms []func(P0 context.Context, P1 *pubsub.ListTopicsRequest) (*pubsub.ListTopicsResponse, error))

ListTopics Enqueue Mocks

func (*ImitPublisherServer) EnqueuePublishMock 

func (imit *ImitPublisherServer) EnqueuePublishMock(m func(P0 context.Context, P1 *pubsub.PublishRequest) (*pubsub.PublishResponse, error))

Publish Enqueue Mock

func (*ImitPublisherServer) EnqueuePublishMocks 

func (imit *ImitPublisherServer) EnqueuePublishMocks(ms []func(P0 context.Context, P1 *pubsub.PublishRequest) (*pubsub.PublishResponse, error))

Publish Enqueue Mocks

func (*ImitPublisherServer) EnqueueUpdateTopicMock 

func (imit *ImitPublisherServer) EnqueueUpdateTopicMock(m func(P0 context.Context, P1 *pubsub.UpdateTopicRequest) (*pubsub.Topic, error))

UpdateTopic Enqueue Mock

func (*ImitPublisherServer) EnqueueUpdateTopicMocks 

func (imit *ImitPublisherServer) EnqueueUpdateTopicMocks(ms []func(P0 context.Context, P1 *pubsub.UpdateTopicRequest) (*pubsub.Topic, error))

UpdateTopic Enqueue Mocks

func (*ImitPublisherServer) GetTopic 

func (imit *ImitPublisherServer) GetTopic(P0 context.Context, P1 *pubsub.GetTopicRequest) (*pubsub.Topic, error)

GetTopic Imitation

func (*ImitPublisherServer) ListTopicSnapshots 

func (imit *ImitPublisherServer) ListTopicSnapshots(P0 context.Context, P1 *pubsub.ListTopicSnapshotsRequest) (*pubsub.ListTopicSnapshotsResponse, error)

ListTopicSnapshots Imitation

func (*ImitPublisherServer) ListTopicSubscriptions 

func (imit *ImitPublisherServer) ListTopicSubscriptions(P0 context.Context, P1 *pubsub.ListTopicSubscriptionsRequest) (*pubsub.ListTopicSubscriptionsResponse, error)

ListTopicSubscriptions Imitation

func (*ImitPublisherServer) ListTopics 

func (imit *ImitPublisherServer) ListTopics(P0 context.Context, P1 *pubsub.ListTopicsRequest) (*pubsub.ListTopicsResponse, error)

ListTopics Imitation

func (*ImitPublisherServer) Publish 

func (imit *ImitPublisherServer) Publish(P0 context.Context, P1 *pubsub.PublishRequest) (*pubsub.PublishResponse, error)

Publish Imitation

func (*ImitPublisherServer) TakeCreateTopicRecords 

func (imit *ImitPublisherServer) TakeCreateTopicRecords() []struct {
	P0 context.Context
	P1 *pubsub.Topic
}

CreateTopic Take Records

func (*ImitPublisherServer) TakeDeleteTopicRecords 

func (imit *ImitPublisherServer) TakeDeleteTopicRecords() []struct {
	P0 context.Context
	P1 *pubsub.DeleteTopicRequest
}

DeleteTopic Take Records

func (*ImitPublisherServer) TakeDetachSubscriptionRecords 

func (imit *ImitPublisherServer) TakeDetachSubscriptionRecords() []struct {
	P0 context.Context
	P1 *pubsub.DetachSubscriptionRequest
}

DetachSubscription Take Records

func (*ImitPublisherServer) TakeGetTopicRecords 

func (imit *ImitPublisherServer) TakeGetTopicRecords() []struct {
	P0 context.Context
	P1 *pubsub.GetTopicRequest
}

GetTopic Take Records

func (*ImitPublisherServer) TakeListTopicSnapshotsRecords 

func (imit *ImitPublisherServer) TakeListTopicSnapshotsRecords() []struct {
	P0 context.Context
	P1 *pubsub.ListTopicSnapshotsRequest
}

ListTopicSnapshots Take Records

func (*ImitPublisherServer) TakeListTopicSubscriptionsRecords 

func (imit *ImitPublisherServer) TakeListTopicSubscriptionsRecords() []struct {
	P0 context.Context
	P1 *pubsub.ListTopicSubscriptionsRequest
}

ListTopicSubscriptions Take Records

func (*ImitPublisherServer) TakeListTopicsRecords 

func (imit *ImitPublisherServer) TakeListTopicsRecords() []struct {
	P0 context.Context
	P1 *pubsub.ListTopicsRequest
}

ListTopics Take Records

func (*ImitPublisherServer) TakePublishRecords 

func (imit *ImitPublisherServer) TakePublishRecords() []struct {
	P0 context.Context
	P1 *pubsub.PublishRequest
}

Publish Take Records

func (*ImitPublisherServer) TakeUpdateTopicRecords 

func (imit *ImitPublisherServer) TakeUpdateTopicRecords() []struct {
	P0 context.Context
	P1 *pubsub.UpdateTopicRequest
}

UpdateTopic Take Records

func (*ImitPublisherServer) UpdateTopic 

func (imit *ImitPublisherServer) UpdateTopic(P0 context.Context, P1 *pubsub.UpdateTopicRequest) (*pubsub.Topic, error)

UpdateTopic Imitation

type ImitSchemaServiceServer 

type ImitSchemaServiceServer struct {
	pubsub.UnimplementedSchemaServiceServer
	// contains filtered or unexported fields
}

func (*ImitSchemaServiceServer) CreateSchema 

func (imit *ImitSchemaServiceServer) CreateSchema(P0 context.Context, P1 *pubsub.CreateSchemaRequest) (*pubsub.Schema, error)

CreateSchema Imitation

func (*ImitSchemaServiceServer) DeleteSchema 

func (imit *ImitSchemaServiceServer) DeleteSchema(P0 context.Context, P1 *pubsub.DeleteSchemaRequest) (*emptypb.Empty, error)

DeleteSchema Imitation

func (*ImitSchemaServiceServer) EnqueueCreateSchemaMock 

func (imit *ImitSchemaServiceServer) EnqueueCreateSchemaMock(m func(P0 context.Context, P1 *pubsub.CreateSchemaRequest) (*pubsub.Schema, error))

CreateSchema Enqueue Mock

func (*ImitSchemaServiceServer) EnqueueCreateSchemaMocks 

func (imit *ImitSchemaServiceServer) EnqueueCreateSchemaMocks(ms []func(P0 context.Context, P1 *pubsub.CreateSchemaRequest) (*pubsub.Schema, error))

CreateSchema Enqueue Mocks

func (*ImitSchemaServiceServer) EnqueueDeleteSchemaMock 

func (imit *ImitSchemaServiceServer) EnqueueDeleteSchemaMock(m func(P0 context.Context, P1 *pubsub.DeleteSchemaRequest) (*emptypb.Empty, error))

DeleteSchema Enqueue Mock

func (*ImitSchemaServiceServer) EnqueueDeleteSchemaMocks 

func (imit *ImitSchemaServiceServer) EnqueueDeleteSchemaMocks(ms []func(P0 context.Context, P1 *pubsub.DeleteSchemaRequest) (*emptypb.Empty, error))

DeleteSchema Enqueue Mocks

func (*ImitSchemaServiceServer) EnqueueGetSchemaMock 

func (imit *ImitSchemaServiceServer) EnqueueGetSchemaMock(m func(P0 context.Context, P1 *pubsub.GetSchemaRequest) (*pubsub.Schema, error))

GetSchema Enqueue Mock

func (*ImitSchemaServiceServer) EnqueueGetSchemaMocks 

func (imit *ImitSchemaServiceServer) EnqueueGetSchemaMocks(ms []func(P0 context.Context, P1 *pubsub.GetSchemaRequest) (*pubsub.Schema, error))

GetSchema Enqueue Mocks

func (*ImitSchemaServiceServer) EnqueueListSchemasMock 

func (imit *ImitSchemaServiceServer) EnqueueListSchemasMock(m func(P0 context.Context, P1 *pubsub.ListSchemasRequest) (*pubsub.ListSchemasResponse, error))

ListSchemas Enqueue Mock

func (*ImitSchemaServiceServer) EnqueueListSchemasMocks 

func (imit *ImitSchemaServiceServer) EnqueueListSchemasMocks(ms []func(P0 context.Context, P1 *pubsub.ListSchemasRequest) (*pubsub.ListSchemasResponse, error))

ListSchemas Enqueue Mocks

func (*ImitSchemaServiceServer) EnqueueValidateMessageMock 

func (imit *ImitSchemaServiceServer) EnqueueValidateMessageMock(m func(P0 context.Context, P1 *pubsub.ValidateMessageRequest) (*pubsub.ValidateMessageResponse, error))

ValidateMessage Enqueue Mock

func (*ImitSchemaServiceServer) EnqueueValidateMessageMocks 

func (imit *ImitSchemaServiceServer) EnqueueValidateMessageMocks(ms []func(P0 context.Context, P1 *pubsub.ValidateMessageRequest) (*pubsub.ValidateMessageResponse, error))

ValidateMessage Enqueue Mocks

func (*ImitSchemaServiceServer) EnqueueValidateSchemaMock 

func (imit *ImitSchemaServiceServer) EnqueueValidateSchemaMock(m func(P0 context.Context, P1 *pubsub.ValidateSchemaRequest) (*pubsub.ValidateSchemaResponse, error))

ValidateSchema Enqueue Mock

func (*ImitSchemaServiceServer) EnqueueValidateSchemaMocks 

func (imit *ImitSchemaServiceServer) EnqueueValidateSchemaMocks(ms []func(P0 context.Context, P1 *pubsub.ValidateSchemaRequest) (*pubsub.ValidateSchemaResponse, error))

ValidateSchema Enqueue Mocks

func (*ImitSchemaServiceServer) GetSchema 

func (imit *ImitSchemaServiceServer) GetSchema(P0 context.Context, P1 *pubsub.GetSchemaRequest) (*pubsub.Schema, error)

GetSchema Imitation

func (*ImitSchemaServiceServer) ListSchemas 

func (imit *ImitSchemaServiceServer) ListSchemas(P0 context.Context, P1 *pubsub.ListSchemasRequest) (*pubsub.ListSchemasResponse, error)

ListSchemas Imitation

func (*ImitSchemaServiceServer) TakeCreateSchemaRecords 

func (imit *ImitSchemaServiceServer) TakeCreateSchemaRecords() []struct {
	P0 context.Context
	P1 *pubsub.CreateSchemaRequest
}

CreateSchema Take Records

func (*ImitSchemaServiceServer) TakeDeleteSchemaRecords 

func (imit *ImitSchemaServiceServer) TakeDeleteSchemaRecords() []struct {
	P0 context.Context
	P1 *pubsub.DeleteSchemaRequest
}

DeleteSchema Take Records

func (*ImitSchemaServiceServer) TakeGetSchemaRecords 

func (imit *ImitSchemaServiceServer) TakeGetSchemaRecords() []struct {
	P0 context.Context
	P1 *pubsub.GetSchemaRequest
}

GetSchema Take Records

func (*ImitSchemaServiceServer) TakeListSchemasRecords 

func (imit *ImitSchemaServiceServer) TakeListSchemasRecords() []struct {
	P0 context.Context
	P1 *pubsub.ListSchemasRequest
}

ListSchemas Take Records

func (*ImitSchemaServiceServer) TakeValidateMessageRecords 

func (imit *ImitSchemaServiceServer) TakeValidateMessageRecords() []struct {
	P0 context.Context
	P1 *pubsub.ValidateMessageRequest
}

ValidateMessage Take Records

func (*ImitSchemaServiceServer) TakeValidateSchemaRecords 

func (imit *ImitSchemaServiceServer) TakeValidateSchemaRecords() []struct {
	P0 context.Context
	P1 *pubsub.ValidateSchemaRequest
}

ValidateSchema Take Records

func (*ImitSchemaServiceServer) ValidateMessage 

func (imit *ImitSchemaServiceServer) ValidateMessage(P0 context.Context, P1 *pubsub.ValidateMessageRequest) (*pubsub.ValidateMessageResponse, error)

ValidateMessage Imitation

func (*ImitSchemaServiceServer) ValidateSchema 

func (imit *ImitSchemaServiceServer) ValidateSchema(P0 context.Context, P1 *pubsub.ValidateSchemaRequest) (*pubsub.ValidateSchemaResponse, error)

ValidateSchema Imitation

type ImitSubscriberServer 

type ImitSubscriberServer struct {
	pubsub.UnimplementedSubscriberServer
	// contains filtered or unexported fields
}

func (*ImitSubscriberServer) Acknowledge 

func (imit *ImitSubscriberServer) Acknowledge(P0 context.Context, P1 *pubsub.AcknowledgeRequest) (*emptypb.Empty, error)

Acknowledge Imitation

func (*ImitSubscriberServer) CreateSnapshot 

func (imit *ImitSubscriberServer) CreateSnapshot(P0 context.Context, P1 *pubsub.CreateSnapshotRequest) (*pubsub.Snapshot, error)

CreateSnapshot Imitation

func (*ImitSubscriberServer) CreateSubscription 

func (imit *ImitSubscriberServer) CreateSubscription(P0 context.Context, P1 *pubsub.Subscription) (*pubsub.Subscription, error)

CreateSubscription Imitation

func (*ImitSubscriberServer) DeleteSnapshot 

func (imit *ImitSubscriberServer) DeleteSnapshot(P0 context.Context, P1 *pubsub.DeleteSnapshotRequest) (*emptypb.Empty, error)

DeleteSnapshot Imitation

func (*ImitSubscriberServer) DeleteSubscription 

func (imit *ImitSubscriberServer) DeleteSubscription(P0 context.Context, P1 *pubsub.DeleteSubscriptionRequest) (*emptypb.Empty, error)

DeleteSubscription Imitation

func (*ImitSubscriberServer) EnqueueAcknowledgeMock 

func (imit *ImitSubscriberServer) EnqueueAcknowledgeMock(m func(P0 context.Context, P1 *pubsub.AcknowledgeRequest) (*emptypb.Empty, error))

Acknowledge Enqueue Mock

func (*ImitSubscriberServer) EnqueueAcknowledgeMocks 

func (imit *ImitSubscriberServer) EnqueueAcknowledgeMocks(ms []func(P0 context.Context, P1 *pubsub.AcknowledgeRequest) (*emptypb.Empty, error))

Acknowledge Enqueue Mocks

func (*ImitSubscriberServer) EnqueueCreateSnapshotMock 

func (imit *ImitSubscriberServer) EnqueueCreateSnapshotMock(m func(P0 context.Context, P1 *pubsub.CreateSnapshotRequest) (*pubsub.Snapshot, error))

CreateSnapshot Enqueue Mock

func (*ImitSubscriberServer) EnqueueCreateSnapshotMocks 

func (imit *ImitSubscriberServer) EnqueueCreateSnapshotMocks(ms []func(P0 context.Context, P1 *pubsub.CreateSnapshotRequest) (*pubsub.Snapshot, error))

CreateSnapshot Enqueue Mocks

func (*ImitSubscriberServer) EnqueueCreateSubscriptionMock 

func (imit *ImitSubscriberServer) EnqueueCreateSubscriptionMock(m func(P0 context.Context, P1 *pubsub.Subscription) (*pubsub.Subscription, error))

CreateSubscription Enqueue Mock

func (*ImitSubscriberServer) EnqueueCreateSubscriptionMocks 

func (imit *ImitSubscriberServer) EnqueueCreateSubscriptionMocks(ms []func(P0 context.Context, P1 *pubsub.Subscription) (*pubsub.Subscription, error))

CreateSubscription Enqueue Mocks

func (*ImitSubscriberServer) EnqueueDeleteSnapshotMock 

func (imit *ImitSubscriberServer) EnqueueDeleteSnapshotMock(m func(P0 context.Context, P1 *pubsub.DeleteSnapshotRequest) (*emptypb.Empty, error))

DeleteSnapshot Enqueue Mock

func (*ImitSubscriberServer) EnqueueDeleteSnapshotMocks 

func (imit *ImitSubscriberServer) EnqueueDeleteSnapshotMocks(ms []func(P0 context.Context, P1 *pubsub.DeleteSnapshotRequest) (*emptypb.Empty, error))

DeleteSnapshot Enqueue Mocks

func (*ImitSubscriberServer) EnqueueDeleteSubscriptionMock 

func (imit *ImitSubscriberServer) EnqueueDeleteSubscriptionMock(m func(P0 context.Context, P1 *pubsub.DeleteSubscriptionRequest) (*emptypb.Empty, error))

DeleteSubscription Enqueue Mock

func (*ImitSubscriberServer) EnqueueDeleteSubscriptionMocks 

func (imit *ImitSubscriberServer) EnqueueDeleteSubscriptionMocks(ms []func(P0 context.Context, P1 *pubsub.DeleteSubscriptionRequest) (*emptypb.Empty, error))

DeleteSubscription Enqueue Mocks

func (*ImitSubscriberServer) EnqueueGetSnapshotMock 

func (imit *ImitSubscriberServer) EnqueueGetSnapshotMock(m func(P0 context.Context, P1 *pubsub.GetSnapshotRequest) (*pubsub.Snapshot, error))

GetSnapshot Enqueue Mock

func (*ImitSubscriberServer) EnqueueGetSnapshotMocks 

func (imit *ImitSubscriberServer) EnqueueGetSnapshotMocks(ms []func(P0 context.Context, P1 *pubsub.GetSnapshotRequest) (*pubsub.Snapshot, error))

GetSnapshot Enqueue Mocks

func (*ImitSubscriberServer) EnqueueGetSubscriptionMock 

func (imit *ImitSubscriberServer) EnqueueGetSubscriptionMock(m func(P0 context.Context, P1 *pubsub.GetSubscriptionRequest) (*pubsub.Subscription, error))

GetSubscription Enqueue Mock

func (*ImitSubscriberServer) EnqueueGetSubscriptionMocks 

func (imit *ImitSubscriberServer) EnqueueGetSubscriptionMocks(ms []func(P0 context.Context, P1 *pubsub.GetSubscriptionRequest) (*pubsub.Subscription, error))

GetSubscription Enqueue Mocks

func (*ImitSubscriberServer) EnqueueListSnapshotsMock 

func (imit *ImitSubscriberServer) EnqueueListSnapshotsMock(m func(P0 context.Context, P1 *pubsub.ListSnapshotsRequest) (*pubsub.ListSnapshotsResponse, error))

ListSnapshots Enqueue Mock

func (*ImitSubscriberServer) EnqueueListSnapshotsMocks 

func (imit *ImitSubscriberServer) EnqueueListSnapshotsMocks(ms []func(P0 context.Context, P1 *pubsub.ListSnapshotsRequest) (*pubsub.ListSnapshotsResponse, error))

ListSnapshots Enqueue Mocks

func (*ImitSubscriberServer) EnqueueListSubscriptionsMock 

func (imit *ImitSubscriberServer) EnqueueListSubscriptionsMock(m func(P0 context.Context, P1 *pubsub.ListSubscriptionsRequest) (*pubsub.ListSubscriptionsResponse, error))

ListSubscriptions Enqueue Mock

func (*ImitSubscriberServer) EnqueueListSubscriptionsMocks 

func (imit *ImitSubscriberServer) EnqueueListSubscriptionsMocks(ms []func(P0 context.Context, P1 *pubsub.ListSubscriptionsRequest) (*pubsub.ListSubscriptionsResponse, error))

ListSubscriptions Enqueue Mocks

func (*ImitSubscriberServer) EnqueueModifyAckDeadlineMock 

func (imit *ImitSubscriberServer) EnqueueModifyAckDeadlineMock(m func(P0 context.Context, P1 *pubsub.ModifyAckDeadlineRequest) (*emptypb.Empty, error))

ModifyAckDeadline Enqueue Mock

func (*ImitSubscriberServer) EnqueueModifyAckDeadlineMocks 

func (imit *ImitSubscriberServer) EnqueueModifyAckDeadlineMocks(ms []func(P0 context.Context, P1 *pubsub.ModifyAckDeadlineRequest) (*emptypb.Empty, error))

ModifyAckDeadline Enqueue Mocks

func (*ImitSubscriberServer) EnqueueModifyPushConfigMock 

func (imit *ImitSubscriberServer) EnqueueModifyPushConfigMock(m func(P0 context.Context, P1 *pubsub.ModifyPushConfigRequest) (*emptypb.Empty, error))

ModifyPushConfig Enqueue Mock

func (*ImitSubscriberServer) EnqueueModifyPushConfigMocks 

func (imit *ImitSubscriberServer) EnqueueModifyPushConfigMocks(ms []func(P0 context.Context, P1 *pubsub.ModifyPushConfigRequest) (*emptypb.Empty, error))

ModifyPushConfig Enqueue Mocks

func (*ImitSubscriberServer) EnqueuePullMock 

func (imit *ImitSubscriberServer) EnqueuePullMock(m func(P0 context.Context, P1 *pubsub.PullRequest) (*pubsub.PullResponse, error))

Pull Enqueue Mock

func (*ImitSubscriberServer) EnqueuePullMocks 

func (imit *ImitSubscriberServer) EnqueuePullMocks(ms []func(P0 context.Context, P1 *pubsub.PullRequest) (*pubsub.PullResponse, error))

Pull Enqueue Mocks

func (*ImitSubscriberServer) EnqueueSeekMock 

func (imit *ImitSubscriberServer) EnqueueSeekMock(m func(P0 context.Context, P1 *pubsub.SeekRequest) (*pubsub.SeekResponse, error))

Seek Enqueue Mock

func (*ImitSubscriberServer) EnqueueSeekMocks 

func (imit *ImitSubscriberServer) EnqueueSeekMocks(ms []func(P0 context.Context, P1 *pubsub.SeekRequest) (*pubsub.SeekResponse, error))

Seek Enqueue Mocks

func (*ImitSubscriberServer) EnqueueStreamingPullMock 

func (imit *ImitSubscriberServer) EnqueueStreamingPullMock(m func(P0 pubsub.Subscriber_StreamingPullServer) error)

StreamingPull Enqueue Mock

func (*ImitSubscriberServer) EnqueueStreamingPullMocks 

func (imit *ImitSubscriberServer) EnqueueStreamingPullMocks(ms []func(P0 pubsub.Subscriber_StreamingPullServer) error)

StreamingPull Enqueue Mocks

func (*ImitSubscriberServer) EnqueueUpdateSnapshotMock 

func (imit *ImitSubscriberServer) EnqueueUpdateSnapshotMock(m func(P0 context.Context, P1 *pubsub.UpdateSnapshotRequest) (*pubsub.Snapshot, error))

UpdateSnapshot Enqueue Mock

func (*ImitSubscriberServer) EnqueueUpdateSnapshotMocks 

func (imit *ImitSubscriberServer) EnqueueUpdateSnapshotMocks(ms []func(P0 context.Context, P1 *pubsub.UpdateSnapshotRequest) (*pubsub.Snapshot, error))

UpdateSnapshot Enqueue Mocks

func (*ImitSubscriberServer) EnqueueUpdateSubscriptionMock 

func (imit *ImitSubscriberServer) EnqueueUpdateSubscriptionMock(m func(P0 context.Context, P1 *pubsub.UpdateSubscriptionRequest) (*pubsub.Subscription, error))

UpdateSubscription Enqueue Mock

func (*ImitSubscriberServer) EnqueueUpdateSubscriptionMocks 

func (imit *ImitSubscriberServer) EnqueueUpdateSubscriptionMocks(ms []func(P0 context.Context, P1 *pubsub.UpdateSubscriptionRequest) (*pubsub.Subscription, error))

UpdateSubscription Enqueue Mocks

func (*ImitSubscriberServer) GetSnapshot 

func (imit *ImitSubscriberServer) GetSnapshot(P0 context.Context, P1 *pubsub.GetSnapshotRequest) (*pubsub.Snapshot, error)

GetSnapshot Imitation

func (*ImitSubscriberServer) GetSubscription 

func (imit *ImitSubscriberServer) GetSubscription(P0 context.Context, P1 *pubsub.GetSubscriptionRequest) (*pubsub.Subscription, error)

GetSubscription Imitation

func (*ImitSubscriberServer) ListSnapshots 

func (imit *ImitSubscriberServer) ListSnapshots(P0 context.Context, P1 *pubsub.ListSnapshotsRequest) (*pubsub.ListSnapshotsResponse, error)

ListSnapshots Imitation

func (*ImitSubscriberServer) ListSubscriptions 

func (imit *ImitSubscriberServer) ListSubscriptions(P0 context.Context, P1 *pubsub.ListSubscriptionsRequest) (*pubsub.ListSubscriptionsResponse, error)

ListSubscriptions Imitation

func (*ImitSubscriberServer) ModifyAckDeadline 

func (imit *ImitSubscriberServer) ModifyAckDeadline(P0 context.Context, P1 *pubsub.ModifyAckDeadlineRequest) (*emptypb.Empty, error)

ModifyAckDeadline Imitation

func (*ImitSubscriberServer) ModifyPushConfig 

func (imit *ImitSubscriberServer) ModifyPushConfig(P0 context.Context, P1 *pubsub.ModifyPushConfigRequest) (*emptypb.Empty, error)

ModifyPushConfig Imitation

func (*ImitSubscriberServer) Pull 

func (imit *ImitSubscriberServer) Pull(P0 context.Context, P1 *pubsub.PullRequest) (*pubsub.PullResponse, error)

Pull Imitation

func (*ImitSubscriberServer) Seek 

func (imit *ImitSubscriberServer) Seek(P0 context.Context, P1 *pubsub.SeekRequest) (*pubsub.SeekResponse, error)

Seek Imitation

func (*ImitSubscriberServer) StreamingPull 

func (imit *ImitSubscriberServer) StreamingPull(P0 pubsub.Subscriber_StreamingPullServer) error

StreamingPull Imitation

func (*ImitSubscriberServer) TakeAcknowledgeRecords 

func (imit *ImitSubscriberServer) TakeAcknowledgeRecords() []struct {
	P0 context.Context
	P1 *pubsub.AcknowledgeRequest
}

Acknowledge Take Records

func (*ImitSubscriberServer) TakeCreateSnapshotRecords 

func (imit *ImitSubscriberServer) TakeCreateSnapshotRecords() []struct {
	P0 context.Context
	P1 *pubsub.CreateSnapshotRequest
}

CreateSnapshot Take Records

func (*ImitSubscriberServer) TakeCreateSubscriptionRecords 

func (imit *ImitSubscriberServer) TakeCreateSubscriptionRecords() []struct {
	P0 context.Context
	P1 *pubsub.Subscription
}

CreateSubscription Take Records

func (*ImitSubscriberServer) TakeDeleteSnapshotRecords 

func (imit *ImitSubscriberServer) TakeDeleteSnapshotRecords() []struct {
	P0 context.Context
	P1 *pubsub.DeleteSnapshotRequest
}

DeleteSnapshot Take Records

func (*ImitSubscriberServer) TakeDeleteSubscriptionRecords 

func (imit *ImitSubscriberServer) TakeDeleteSubscriptionRecords() []struct {
	P0 context.Context
	P1 *pubsub.DeleteSubscriptionRequest
}

DeleteSubscription Take Records

func (*ImitSubscriberServer) TakeGetSnapshotRecords 

func (imit *ImitSubscriberServer) TakeGetSnapshotRecords() []struct {
	P0 context.Context
	P1 *pubsub.GetSnapshotRequest
}

GetSnapshot Take Records

func (*ImitSubscriberServer) TakeGetSubscriptionRecords 

func (imit *ImitSubscriberServer) TakeGetSubscriptionRecords() []struct {
	P0 context.Context
	P1 *pubsub.GetSubscriptionRequest
}

GetSubscription Take Records

func (*ImitSubscriberServer) TakeListSnapshotsRecords 

func (imit *ImitSubscriberServer) TakeListSnapshotsRecords() []struct {
	P0 context.Context
	P1 *pubsub.ListSnapshotsRequest
}

ListSnapshots Take Records

func (*ImitSubscriberServer) TakeListSubscriptionsRecords 

func (imit *ImitSubscriberServer) TakeListSubscriptionsRecords() []struct {
	P0 context.Context
	P1 *pubsub.ListSubscriptionsRequest
}

ListSubscriptions Take Records

func (*ImitSubscriberServer) TakeModifyAckDeadlineRecords 

func (imit *ImitSubscriberServer) TakeModifyAckDeadlineRecords() []struct {
	P0 context.Context
	P1 *pubsub.ModifyAckDeadlineRequest
}

ModifyAckDeadline Take Records

func (*ImitSubscriberServer) TakeModifyPushConfigRecords 

func (imit *ImitSubscriberServer) TakeModifyPushConfigRecords() []struct {
	P0 context.Context
	P1 *pubsub.ModifyPushConfigRequest
}

ModifyPushConfig Take Records

func (*ImitSubscriberServer) TakePullRecords 

func (imit *ImitSubscriberServer) TakePullRecords() []struct {
	P0 context.Context
	P1 *pubsub.PullRequest
}

Pull Take Records

func (*ImitSubscriberServer) TakeSeekRecords 

func (imit *ImitSubscriberServer) TakeSeekRecords() []struct {
	P0 context.Context
	P1 *pubsub.SeekRequest
}

Seek Take Records

func (*ImitSubscriberServer) TakeStreamingPullRecords 

func (imit *ImitSubscriberServer) TakeStreamingPullRecords() []struct {
	P0 pubsub.Subscriber_StreamingPullServer
}

StreamingPull Take Records

func (*ImitSubscriberServer) TakeUpdateSnapshotRecords 

func (imit *ImitSubscriberServer) TakeUpdateSnapshotRecords() []struct {
	P0 context.Context
	P1 *pubsub.UpdateSnapshotRequest
}

UpdateSnapshot Take Records

func (*ImitSubscriberServer) TakeUpdateSubscriptionRecords 

func (imit *ImitSubscriberServer) TakeUpdateSubscriptionRecords() []struct {
	P0 context.Context
	P1 *pubsub.UpdateSubscriptionRequest
}

UpdateSubscription Take Records

func (*ImitSubscriberServer) UpdateSnapshot 

func (imit *ImitSubscriberServer) UpdateSnapshot(P0 context.Context, P1 *pubsub.UpdateSnapshotRequest) (*pubsub.Snapshot, error)

UpdateSnapshot Imitation

func (*ImitSubscriberServer) UpdateSubscription 

func (imit *ImitSubscriberServer) UpdateSubscription(P0 context.Context, P1 *pubsub.UpdateSubscriptionRequest) (*pubsub.Subscription, error)

UpdateSubscription Imitation

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.