mock

package

Go to main page

Versions in this module

v0

v0.12.0

Oct 23, 2023

v0.11.0

Oct 11, 2023

Changes in this version

+ const SetTopicPolicyRPC

type Ensign

+ OnSetTopicPolicy func(context.Context, *api.TopicPolicy) (*api.TopicStatus, error)

+ func (s *Ensign) SetTopicPolicy(ctx context.Context, in *api.TopicPolicy) (*api.TopicStatus, error)

v0.10.0

Sep 29, 2023

v0.9.1

Aug 16, 2023

v0.9.0

Aug 16, 2023

Changes in this version

+ const EnSQLRPC

type Ensign

+ OnEnSQL func(*api.Query, api.Ensign_EnSQLServer) error

+ func (s *Ensign) EnSQL(in *api.Query, stream api.Ensign_EnSQLServer) error

v0.8.0

Aug 2, 2023

v0.7.1

Jun 13, 2023

v0.7.0

May 31, 2023

Changes in this version

+ const InfoRPC

+ func NewEvent() *api.Event

+ func NewEventWrapper() *api.EventWrapper

type Ensign

+ OnInfo func(context.Context, *api.InfoRequest) (*api.ProjectInfo, error)

+ func (s *Ensign) Info(ctx context.Context, in *api.InfoRequest) (*api.ProjectInfo, error)

+ type EventFactory struct

+ Region region.Region

+ Topic ulid.ULID

+ func (f *EventFactory) Event() *api.Event

+ func (f *EventFactory) Make() *api.EventWrapper

+ type PublishHandler struct

+ OnEvent func(in *api.EventWrapper) (out *api.PublisherReply, err error)

+ OnInitialize func(in *api.OpenStream) (out *api.StreamReady, err error)

+ func NewPublishHandler(topics map[string]ulid.ULID) *PublishHandler

+ func (s *PublishHandler) OnPublish(stream api.Ensign_PublishServer) (err error)

+ type SubscribeHandler struct

+ OnAck func(in *api.Ack) (err error)

+ OnInitialize func(in *api.Subscription) (out *api.StreamReady, err error)

+ OnNack func(in *api.Nack) (err error)

+ Send chan<- *api.EventWrapper

+ func NewSubscribeHandler() *SubscribeHandler

+ func (s *SubscribeHandler) OnSubscribe(stream api.Ensign_SubscribeServer) (err error)

+ func (s *SubscribeHandler) Shutdown()

+ func (s *SubscribeHandler) UseTopicMap(topics map[string]ulid.ULID)

v0.6.0

Apr 11, 2023

Changes in this version

+ const RetrieveTopicRPC

+ const TopicExistsRPC

+ const TopicNamesRPC

+ var ErrUnavailable = status.Error(codes.Unavailable, "mock method has not been configured")

type Ensign

+ OnRetrieveTopic func(context.Context, *api.Topic) (*api.Topic, error)

+ OnTopicExists func(context.Context, *api.TopicName) (*api.TopicExistsInfo, error)

+ OnTopicNames func(context.Context, *api.PageInfo) (*api.TopicNamesPage, error)

+ func (s *Ensign) RetrieveTopic(ctx context.Context, in *api.Topic) (*api.Topic, error)

+ func (s *Ensign) TopicExists(ctx context.Context, in *api.TopicName) (*api.TopicExistsInfo, error)

+ func (s *Ensign) TopicNames(ctx context.Context, in *api.PageInfo) (*api.TopicNamesPage, error)

v0.5.1

Mar 21, 2023

v0.4.2

Mar 14, 2023

Changes in this version

+ const CreateTopicRPC

+ const DeleteTopicRPC

+ const ListTopicsRPC

+ const PublishRPC

+ const StatusRPC

+ const SubscribeRPC

+ type DialOption func(*Listener)

+ func WithBuffer(sock *bufconn.Listener) DialOption

+ func WithBufferSize(size int) DialOption

+ func WithTarget(target string) DialOption

+ type Ensign struct

+ Calls map[string]int

+ OnCreateTopic func(context.Context, *api.Topic) (*api.Topic, error)

+ OnDeleteTopic func(context.Context, *api.TopicMod) (*api.TopicTombstone, error)

+ OnListTopics func(context.Context, *api.PageInfo) (*api.TopicsPage, error)

+ OnPublish func(api.Ensign_PublishServer) error

+ OnStatus func(context.Context, *api.HealthCheck) (*api.ServiceState, error)

+ OnSubscribe func(api.Ensign_SubscribeServer) error

+ func New(bufnet *Listener, opts ...grpc.ServerOption) *Ensign

+ func (s *Ensign) Client(ctx context.Context, opts ...grpc.DialOption) (client api.EnsignClient, err error)

+ func (s *Ensign) CreateTopic(ctx context.Context, in *api.Topic) (*api.Topic, error)

+ func (s *Ensign) DeleteTopic(ctx context.Context, in *api.TopicMod) (*api.TopicTombstone, error)

+ func (s *Ensign) ListTopics(ctx context.Context, in *api.PageInfo) (*api.TopicsPage, error)

+ func (s *Ensign) Publish(stream api.Ensign_PublishServer) error

+ func (s *Ensign) Reset()

+ func (s *Ensign) ResetClient(ctx context.Context, opts ...grpc.DialOption) (api.EnsignClient, error)

+ func (s *Ensign) Shutdown()

+ func (s *Ensign) Status(ctx context.Context, in *api.HealthCheck) (*api.ServiceState, error)

+ func (s *Ensign) Subscribe(stream api.Ensign_SubscribeServer) error

+ func (s *Ensign) UseError(rpc string, code codes.Code, msg string) error

+ func (s *Ensign) UseFixture(rpc, path string) (err error)

+ type Listener struct

+ func NewBufConn(opts ...DialOption) *Listener

+ func (l *Listener) Close() error

+ func (l *Listener) Connect(ctx context.Context, opts ...grpc.DialOption) (cc *grpc.ClientConn, err error)

+ func (l *Listener) Dialer(context.Context, string) (net.Conn, error)

+ func (l *Listener) Sock() net.Listener

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL