api

Documentation

Index

• type Client
  • func NewClient(id string, key string, client pb.ApiClient) *Client
  • func (c *Client) AddEvent(event *pb.Event) error
  • func (c *Client) CrtInfo(info *pb.CertificateInfo) error
  • func (c *Client) WorkloadStream(msg *pb.WorkloadMessage) error
• type MockBcloudClient
  • func (m *MockBcloudClient) AddEvent(ctx context.Context, event *pb.Event, _ ...grpc.CallOption) (*pb.Empty, error)
  • func (m *MockBcloudClient) CloseAndRecv() (*pb.Empty, error)
  • func (m *MockBcloudClient) CloseSend() error
  • func (m *MockBcloudClient) Context() context.Context
  • func (m *MockBcloudClient) Events() []*pb.Event
  • func (m *MockBcloudClient) Header() (metadata.MD, error)
  • func (m *MockBcloudClient) LinkerdInfo(ctx context.Context, message *pb.LinkerdMessage, _ ...grpc.CallOption) (*pb.Empty, error)
  • func (m *MockBcloudClient) LinkerdMessages() []*pb.LinkerdMessage
  • func (m *MockBcloudClient) Messages() []*pb.WorkloadMessage
  • func (m *MockBcloudClient) RecvMsg(_ interface{}) error
  • func (m *MockBcloudClient) Send(msg *pb.WorkloadMessage) error
  • func (m *MockBcloudClient) SendMsg(_ interface{}) error
  • func (m *MockBcloudClient) Trailer() metadata.MD
  • func (m *MockBcloudClient) WorkloadStream(ctx context.Context, _ ...grpc.CallOption) (pb.Api_WorkloadStreamClient, error)

Types

type Client

type Client struct {

	// protects stream
	sync.Mutex
	// contains filtered or unexported fields
}

Client provides a simple Buoyant Cloud API client.

func NewClient

func NewClient(id string, key string, client pb.ApiClient) *Client

NewClient instantiates a new Buoyant Cloud API client.

func (*Client) AddEvent

func (c *Client) AddEvent(event *pb.Event) error

AddEvent wraps the Buoyant Cloud API AddEvent gRPC unary endpoint.

func (*Client) CrtInfo

func (c *Client) CrtInfo(info *pb.CertificateInfo) error

func (*Client) WorkloadStream

func (c *Client) WorkloadStream(msg *pb.WorkloadMessage) error

WorkloadStream wraps the Buoyant Cloud API WorkloadStream gRPC endpoint, and manages the client-side stream.

type MockBcloudClient

type MockBcloudClient struct {

	// protects messages and events
	sync.Mutex
	// contains filtered or unexported fields
}

MockBcloudClient satisfies the bcloud.ApiClient and bcloud.Api_WorkloadStreamClient interfaces, and saves all params and messages passed to it.

func (*MockBcloudClient) AddEvent

func (m *MockBcloudClient) AddEvent(
	ctx context.Context, event *pb.Event, _ ...grpc.CallOption,
) (*pb.Empty, error)

func (*MockBcloudClient) CloseAndRecv

func (m *MockBcloudClient) CloseAndRecv() (*pb.Empty, error)

func (*MockBcloudClient) CloseSend

func (m *MockBcloudClient) CloseSend() error

func (*MockBcloudClient) Context

func (m *MockBcloudClient) Context() context.Context

func (*MockBcloudClient) Events

func (m *MockBcloudClient) Events() []*pb.Event

func (*MockBcloudClient) Header

func (m *MockBcloudClient) Header() (metadata.MD, error)

func (*MockBcloudClient) LinkerdInfo

func (m *MockBcloudClient) LinkerdInfo(
	ctx context.Context, message *pb.LinkerdMessage, _ ...grpc.CallOption,
) (*pb.Empty, error)

func (*MockBcloudClient) LinkerdMessages

func (m *MockBcloudClient) LinkerdMessages() []*pb.LinkerdMessage

func (*MockBcloudClient) Messages

func (m *MockBcloudClient) Messages() []*pb.WorkloadMessage

func (*MockBcloudClient) RecvMsg

func (m *MockBcloudClient) RecvMsg(_ interface{}) error

func (*MockBcloudClient) Send

func (m *MockBcloudClient) Send(msg *pb.WorkloadMessage) error

func (*MockBcloudClient) SendMsg

func (m *MockBcloudClient) SendMsg(_ interface{}) error

func (*MockBcloudClient) Trailer

func (m *MockBcloudClient) Trailer() metadata.MD

func (*MockBcloudClient) WorkloadStream

func (m *MockBcloudClient) WorkloadStream(
	ctx context.Context, _ ...grpc.CallOption,
) (pb.Api_WorkloadStreamClient, error)