client

Documentation

Index

• Constants
• func NewDatameshConn() (*grpc.ClientConn, error)
• func NewGrpcConn(address string, tlsconfig *config.TLSConfig, tokenFile string) (*grpc.ClientConn, error)
• func NewKusciaAPIConn() (*grpc.ClientConn, error)
• type Client
  • func NewDiagnoseClient(hostName string) *Client
  • func (c *Client) Done(ctx context.Context) (response *diagnose.StatusResponse, err error)
  • func (c *Client) Healthy(ctx context.Context) (response *diagnose.StatusResponse, err error)
  • func (c *Client) Mock(ctx context.Context, request *diagnose.MockRequest) (response *diagnose.MockResponse, err error)
  • func (c *Client) MockChunk(req proto.Message, url string) (*http.Response, error)
  • func (c *Client) RegisterEndpoint(ctx context.Context, request *diagnose.RegisterEndpointRequest) (response *diagnose.StatusResponse, err error)
  • func (c *Client) SubmitReport(ctx context.Context, request *diagnose.SubmitReportRequest) (response *diagnose.StatusResponse, err error)

Constants

const (
	DatameshServerHost = "datamesh:8071"
)

Functions

func NewDatameshConn

func NewDatameshConn() (*grpc.ClientConn, error)

func NewGrpcConn

func NewGrpcConn(address string, tlsconfig *config.TLSConfig, tokenFile string) (*grpc.ClientConn, error)

func NewKusciaAPIConn

func NewKusciaAPIConn() (*grpc.ClientConn, error)

Types

type Client

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

func NewDiagnoseClient

func NewDiagnoseClient(hostName string) *Client

func (*Client) Done

func (c *Client) Done(ctx context.Context) (response *diagnose.StatusResponse, err error)

func (*Client) Healthy

func (c *Client) Healthy(ctx context.Context) (response *diagnose.StatusResponse, err error)

func (*Client) Mock

func (c *Client) Mock(ctx context.Context, request *diagnose.MockRequest) (response *diagnose.MockResponse, err error)

func (*Client) MockChunk

func (c *Client) MockChunk(req proto.Message, url string) (*http.Response, error)

func (*Client) RegisterEndpoint

func (c *Client) RegisterEndpoint(ctx context.Context, request *diagnose.RegisterEndpointRequest) (response *diagnose.StatusResponse, err error)

func (*Client) SubmitReport

func (c *Client) SubmitReport(ctx context.Context, request *diagnose.SubmitReportRequest) (response *diagnose.StatusResponse, err error)