segmentwriterclient

Documentation

Index

• type Client
  • func NewSegmentWriterClient(grpcClientConfig grpcclient.Config, logger log.Logger, ...) (*Client, error)
  • func (c *Client) Push(ctx context.Context, req *segmentwriterv1.PushRequest) (resp *segmentwriterv1.PushResponse, err error)
  • func (c *Client) Service() services.Service

Types

type Client

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

func NewSegmentWriterClient

func NewSegmentWriterClient(
	grpcClientConfig grpcclient.Config,
	logger log.Logger,
	registry prometheus.Registerer,
	ring ring.ReadRing,
	placement placement.Placement,
	dialOpts ...grpc.DialOption,
) (*Client, error)

func (*Client) Push

func (c *Client) Push(
	ctx context.Context,
	req *segmentwriterv1.PushRequest,
) (resp *segmentwriterv1.PushResponse, err error)

func (*Client) Service

func (c *Client) Service() services.Service