fumarole_geyser

Documentation

Index

• type Client
  • func New(ctx context.Context, grpcDialURL string, md metadata.MD, ...) (*Client, error)
  • func (c *Client) AddStreamClient(ctx context.Context, streamName string, opts ...grpc.CallOption) (*StreamClient, error)
  • func (c *Client) Close() error
• type StreamClient
  • func (s *StreamClient) CreateStaticConsumerGroup(label string, memberCount uint32, initialOffsetPolicy pb.InitialOffsetPolicy, ...) (*pb.CreateStaticConsumerGroupResponse, error)
  • func (s *StreamClient) DeleteConsumerGroup(label string) (*pb.DeleteConsumerGroupResponse, error)
  • func (s *StreamClient) GetConsumerGroupInfo(label string) (*pb.ConsumerGroupInfo, error)
  • func (s *StreamClient) GetOldestSlot(commitmentLevel pb.CommitmentLevel) (*pb.GetOldestSlotResponse, error)
  • func (s *StreamClient) GetSlotLagInfo(label string) (*pb.GetSlotLagInfoResponse, error)
  • func (s *StreamClient) ListAvailableCommitmentLevels() (*pb.ListAvailableCommitmentLevelsResponse, error)
  • func (s *StreamClient) ListConsumerGroups() (*pb.ListConsumerGroupsResponse, error)
  • func (s *StreamClient) Stop()
  • func (s *StreamClient) Subscribe(req *pb.SubscribeRequest) error

Types

type Client

type Client struct {
	Ctx      context.Context
	Cancel   context.CancelFunc
	GrpcConn *grpc.ClientConn
	Fumarole pb.FumaroleClient
	ErrCh    chan error
	// contains filtered or unexported fields
}

Client represents a client for the Fumarole service.

func New

func New(ctx context.Context, grpcDialURL string, md metadata.MD, opts ...grpc.DialOption) (*Client, error)

New creates a new Client instance.

func (*Client) AddStreamClient

func (c *Client) AddStreamClient(ctx context.Context, streamName string, opts ...grpc.CallOption) (*StreamClient, error)

AddStreamClient creates a new Fumarole subscribe stream client.

func (*Client) Close

func (c *Client) Close() error

Close closes the client and all the streams.

type StreamClient

type StreamClient struct {
	Ctx      context.Context
	Cancel   context.CancelFunc
	GrpcConn *grpc.ClientConn

	Ch    chan *pb.SubscribeUpdate
	ErrCh chan error
	// contains filtered or unexported fields
}

StreamClient represents a client for a specific stream.

func (*StreamClient) CreateStaticConsumerGroup

func (s *StreamClient) CreateStaticConsumerGroup(
	label string,
	memberCount uint32,
	initialOffsetPolicy pb.InitialOffsetPolicy,
	commitmentLevel pb.CommitmentLevel,
	eventSubPolicy pb.EventSubscriptionPolicy,
	atSlot int64,
) (*pb.CreateStaticConsumerGroupResponse, error)

func (*StreamClient) DeleteConsumerGroup

func (s *StreamClient) DeleteConsumerGroup(label string) (*pb.DeleteConsumerGroupResponse, error)

func (*StreamClient) GetConsumerGroupInfo

func (s *StreamClient) GetConsumerGroupInfo(label string) (*pb.ConsumerGroupInfo, error)

func (*StreamClient) GetOldestSlot

func (s *StreamClient) GetOldestSlot(commitmentLevel pb.CommitmentLevel) (*pb.GetOldestSlotResponse, error)

func (*StreamClient) GetSlotLagInfo

func (s *StreamClient) GetSlotLagInfo(label string) (*pb.GetSlotLagInfoResponse, error)

func (*StreamClient) ListAvailableCommitmentLevels

func (s *StreamClient) ListAvailableCommitmentLevels() (*pb.ListAvailableCommitmentLevelsResponse, error)

func (*StreamClient) ListConsumerGroups

func (s *StreamClient) ListConsumerGroups() (*pb.ListConsumerGroupsResponse, error)

func (*StreamClient) Stop

func (s *StreamClient) Stop()

func (*StreamClient) Subscribe

func (s *StreamClient) Subscribe(req *pb.SubscribeRequest) error