luci: Index | Files

package bundleServicesClient

import ""


Package Files


type Client Uses

type Client struct {
    // ServicesClient is the Coordinator Services endpoint Client that is being
    // wrapped.

    // Starting from the time that the first message is added to a bundle, once
    // this delay has passed, handle the bundle.
    // The default is bundler.DefaultDelayThreshold.
    DelayThreshold time.Duration

    // Once a bundle has this many items, handle the bundle. Since only one
    // item at a time is added to a bundle, no bundle will exceed this
    // threshold, so it also serves as a limit.
    // The default is bundler.DefaultBundleCountThreshold.
    BundleCountThreshold int
    // contains filtered or unexported fields

Client is a LogDog Coordinator Services endpoint client that intercepts calls that can be batched and buffers them, sending them with the Batch RPC instead of their independent individual RPCs.

The Context and CallOption set for the first intercepted call will be used when making the batch call; all other CallOption sets will be ignored.

Bundling parameters can be controlled by modifying the Bundler prior to invoking it.

func (*Client) ArchiveStream Uses

func (c *Client) ArchiveStream(ctx context.Context, in *s.ArchiveStreamRequest, opts ...grpc.CallOption) (
    *empty.Empty, error)

ArchiveStream implements ServicesClient.

func (*Client) Flush Uses

func (c *Client) Flush()

Flush flushes the Bundler. It should be called when terminating to ensure that buffered client requests have been completed.

func (*Client) LoadStream Uses

func (c *Client) LoadStream(ctx context.Context, in *s.LoadStreamRequest, opts ...grpc.CallOption) (
    *s.LoadStreamResponse, error)

LoadStream implements ServicesClient.

func (*Client) RegisterStream Uses

func (c *Client) RegisterStream(ctx context.Context, in *s.RegisterStreamRequest, opts ...grpc.CallOption) (
    *s.RegisterStreamResponse, error)

RegisterStream implements ServicesClient.

func (*Client) TerminateStream Uses

func (c *Client) TerminateStream(ctx context.Context, in *s.TerminateStreamRequest, opts ...grpc.CallOption) (
    *empty.Empty, error)

TerminateStream implements ServicesClient.

Package bundleServicesClient imports 11 packages (graph). Updated 2021-01-24. Refresh now. Tools for package owners.