client

Documentation

Index

• type ConfigureData
• type Format
  • func MustParseFormat(s string) Format
• type FormatWriter
  • func NewFormatWriter(w io.Writer, format Format) *FormatWriter
  • func (f *FormatWriter) WriteAndClose(headers []string, items [][]string) error
• type GrpcClient
  • func NewGrpcClient(serverAddr string) (*GrpcClient, error)
  • func (g *GrpcClient) WaitForReconnect(ctx context.Context) error
• type GrpcConnCloser
• type GrpcLazyClient
  • func NewGrpcLazyClinet(serverAddr string) (*GrpcLazyClient, error)
  • func (l *GrpcLazyClient) Close() error
  • func (l *GrpcLazyClient) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error
  • func (l *GrpcLazyClient) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
• type LocalFileConfigure
  • func NewLocalFileConfigure(localfile string) *LocalFileConfigure
  • func (l *LocalFileConfigure) Load() error
  • func (l *LocalFileConfigure) Save() error

Types

type ConfigureData

type ConfigureData struct {
	Token         string    `json:"token"`
	LastLoginTime time.Time `json:"lastLoginTime"`
}

type Format

type Format string

const (
	UnknownFormat Format = "unknown"
	Table         Format = "table"
	CSV           Format = "csv"
)

func MustParseFormat

func MustParseFormat(s string) Format

type FormatWriter

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

func NewFormatWriter

func NewFormatWriter(w io.Writer, format Format) *FormatWriter

func (*FormatWriter) WriteAndClose

func (f *FormatWriter) WriteAndClose(headers []string, items [][]string) error

type GrpcClient

type GrpcClient struct {
	*grpc.ClientConn
}

func NewGrpcClient

func NewGrpcClient(serverAddr string) (*GrpcClient, error)

func (*GrpcClient) WaitForReconnect

func (g *GrpcClient) WaitForReconnect(ctx context.Context) error

type GrpcConnCloser

type GrpcConnCloser interface {
	Close() error
}

type GrpcLazyClient

type GrpcLazyClient struct {
	*GrpcClient
	// contains filtered or unexported fields
}

func NewGrpcLazyClinet

func NewGrpcLazyClinet(serverAddr string) (*GrpcLazyClient, error)

func (*GrpcLazyClient) Close

func (l *GrpcLazyClient) Close() error

func (*GrpcLazyClient) Invoke

func (l *GrpcLazyClient) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error

func (*GrpcLazyClient) NewStream

func (l *GrpcLazyClient) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)

type LocalFileConfigure

type LocalFileConfigure struct {
	Data *ConfigureData
	// contains filtered or unexported fields
}

func NewLocalFileConfigure

func NewLocalFileConfigure(localfile string) *LocalFileConfigure

func (*LocalFileConfigure) Load

func (l *LocalFileConfigure) Load() error

func (*LocalFileConfigure) Save

func (l *LocalFileConfigure) Save() error