client

Documentation

Index

• type Client
  • func NewClient(opts CsubClientOptions) (Client, error)
  • func NewMockClient() (Client, error)
• type CsubClientOptions
  • func ValidateCsubClientFlags(addr string, tls bool, tlsSkipVerify bool) (CsubClientOptions, error)
• type MockClient
  • func (c *MockClient) AddCollectEntries(ctx context.Context, entries []*pb.CollectEntry) error
  • func (c *MockClient) Close()
  • func (c *MockClient) GetCollectEntries(ctx context.Context, filters []*pb.CollectEntryFilter) ([]*pb.CollectEntry, error)

Types

type Client

type Client interface {
	AddCollectEntries(ctx context.Context, entries []*pb.CollectEntry) error
	GetCollectEntries(ctx context.Context, filters []*pb.CollectEntryFilter) ([]*pb.CollectEntry, error)
	Close()
}

func NewClient

func NewClient(opts CsubClientOptions) (Client, error)

func NewMockClient

func NewMockClient() (Client, error)

type CsubClientOptions

type CsubClientOptions struct {
	Addr          string
	Tls           bool
	TlsSkipVerify bool
}

func ValidateCsubClientFlags

func ValidateCsubClientFlags(addr string, tls bool, tlsSkipVerify bool) (CsubClientOptions, error)

type MockClient

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

MockClient is a simple mock client to simulate being connected to a server

func (*MockClient) AddCollectEntries

func (c *MockClient) AddCollectEntries(ctx context.Context, entries []*pb.CollectEntry) error

func (*MockClient) Close

func (c *MockClient) Close()

func (*MockClient) GetCollectEntries

func (c *MockClient) GetCollectEntries(ctx context.Context, filters []*pb.CollectEntryFilter) ([]*pb.CollectEntry, error)