client

Documentation

Index

• Constants
• func Status(err error) int
• type Client
  • func NewClient(config *Config) (Client, error)
  • func NewGRPCClient(c *Config) (Client, error)
  • func NewRESTClient(c *Config) (Client, error)
• type Config
  • func (c *Config) ClientTLSConfig() (*tls.Config, error)
• type Credentials
  • func (c *Credentials) GetRequestMetadata(ctx context.Context, _ ...string) (map[string]string, error)
  • func (c *Credentials) RequireTransportSecurity() bool
• type GRPCClient
• type RESTClient
  • func (c *RESTClient) CreateRecord(_ context.Context, _ *v1alpha2.CreateRecordRequest, _ ...grpc.CallOption) (*v1alpha2.Record, error)
  • func (c *RESTClient) CreateResult(_ context.Context, _ *v1alpha2.CreateResultRequest, _ ...grpc.CallOption) (*v1alpha2.Result, error)
  • func (c *RESTClient) DeleteLog(ctx context.Context, in *v1alpha2.DeleteLogRequest, _ ...grpc.CallOption) (*emptypb.Empty, error)
  • func (c *RESTClient) DeleteRecord(ctx context.Context, in *v1alpha2.DeleteRecordRequest, _ ...grpc.CallOption) (*emptypb.Empty, error)
  • func (c *RESTClient) DeleteResult(ctx context.Context, in *v1alpha2.DeleteResultRequest, _ ...grpc.CallOption) (*emptypb.Empty, error)
  • func (c *RESTClient) GetLog(ctx context.Context, in *v1alpha3.GetLogRequest, _ ...grpc.CallOption) (v1alpha2.Logs_GetLogClient, error)
  • func (c *RESTClient) GetRecord(ctx context.Context, in *v1alpha2.GetRecordRequest, _ ...grpc.CallOption) (*v1alpha2.Record, error)
  • func (c *RESTClient) GetRecordListSummary(ctx context.Context, _ *v1alpha2.RecordListSummaryRequest, ...) (*v1alpha2.RecordListSummary, error)
  • func (c *RESTClient) GetResult(ctx context.Context, in *v1alpha2.GetResultRequest, _ ...grpc.CallOption) (*v1alpha2.Result, error)
  • func (c *RESTClient) ListLogs(ctx context.Context, in *v1alpha2.ListRecordsRequest, _ ...grpc.CallOption) (*v1alpha2.ListRecordsResponse, error)
  • func (c *RESTClient) ListRecords(ctx context.Context, in *v1alpha2.ListRecordsRequest, _ ...grpc.CallOption) (*v1alpha2.ListRecordsResponse, error)
  • func (c *RESTClient) ListResults(ctx context.Context, in *v1alpha2.ListResultsRequest, _ ...grpc.CallOption) (*v1alpha2.ListResultsResponse, error)
  • func (c *RESTClient) UpdateLog(_ context.Context, _ ...grpc.CallOption) (v1alpha2.Logs_UpdateLogClient, error)
  • func (c *RESTClient) UpdateRecord(_ context.Context, _ *v1alpha2.UpdateRecordRequest, _ ...grpc.CallOption) (*v1alpha2.Record, error)
  • func (c *RESTClient) UpdateResult(_ context.Context, _ *v1alpha2.UpdateResultRequest, _ ...grpc.CallOption) (*v1alpha2.Result, error)

Constants

const (
	GRPC = "GRPC"
	REST = "REST"
)

Functions

func Status

func Status(err error) int

Types

type Client

type Client interface {
	resultsv1alpha3.LogsClient
	resultsv1alpha2.ResultsClient
}

func NewClient

func NewClient(config *Config) (Client, error)

func NewGRPCClient

func NewGRPCClient(c *Config) (Client, error)

NewGRPCClient creates a new gRPC client.

func NewRESTClient

func NewRESTClient(c *Config) (Client, error)

NewRESTClient creates a new REST client.

type Config

type Config struct {
	ClientType string
	URL        *url.URL
	Timeout    time.Duration
	Transport  *transport.Config
}

func (*Config) ClientTLSConfig

func (c *Config) ClientTLSConfig() (*tls.Config, error)

type Credentials

type Credentials struct {
	oauth2.TokenSource
	*transport.ImpersonationConfig
	SkipTransportSecurity bool
}

Credentials supplies PerRPCCredentials from a Token Source and Impersonation config.

func (*Credentials) GetRequestMetadata

func (c *Credentials) GetRequestMetadata(ctx context.Context, _ ...string) (map[string]string, error)

GetRequestMetadata gets the request metadata as a map from a Custom.

func (*Credentials) RequireTransportSecurity

func (c *Credentials) RequireTransportSecurity() bool

RequireTransportSecurity indicates whether the credentials requires transport security.

type GRPCClient

type GRPCClient struct {
	resultsv1alpha3.LogsClient
	resultsv1alpha2.ResultsClient
}

type RESTClient

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

func (*RESTClient) CreateRecord

func (c *RESTClient) CreateRecord(_ context.Context, _ *v1alpha2.CreateRecordRequest, _ ...grpc.CallOption) (*v1alpha2.Record, error)

func (*RESTClient) CreateResult

func (c *RESTClient) CreateResult(_ context.Context, _ *v1alpha2.CreateResultRequest, _ ...grpc.CallOption) (*v1alpha2.Result, error)

func (*RESTClient) DeleteLog

func (c *RESTClient) DeleteLog(ctx context.Context, in *v1alpha2.DeleteLogRequest, _ ...grpc.CallOption) (*emptypb.Empty, error)

DeleteLog Functionality not supported now

func (*RESTClient) DeleteRecord

func (c *RESTClient) DeleteRecord(ctx context.Context, in *v1alpha2.DeleteRecordRequest, _ ...grpc.CallOption) (*emptypb.Empty, error)

DeleteRecord makes request to delete record

func (*RESTClient) DeleteResult

func (c *RESTClient) DeleteResult(ctx context.Context, in *v1alpha2.DeleteResultRequest, _ ...grpc.CallOption) (*emptypb.Empty, error)

DeleteResult makes request to delete result

func (*RESTClient) GetLog

func (c *RESTClient) GetLog(ctx context.Context, in *v1alpha3.GetLogRequest, _ ...grpc.CallOption) (v1alpha2.Logs_GetLogClient, error)

func (*RESTClient) GetRecord

func (c *RESTClient) GetRecord(ctx context.Context, in *v1alpha2.GetRecordRequest, _ ...grpc.CallOption) (*v1alpha2.Record, error)

GetRecord makes request to get record

func (*RESTClient) GetRecordListSummary

func (c *RESTClient) GetRecordListSummary(ctx context.Context, _ *v1alpha2.RecordListSummaryRequest, _ ...grpc.CallOption) (*v1alpha2.RecordListSummary, error)

func (*RESTClient) GetResult

func (c *RESTClient) GetResult(ctx context.Context, in *v1alpha2.GetResultRequest, _ ...grpc.CallOption) (*v1alpha2.Result, error)

GetResult makes request to get result

func (*RESTClient) ListLogs

func (c *RESTClient) ListLogs(ctx context.Context, in *v1alpha2.ListRecordsRequest, _ ...grpc.CallOption) (*v1alpha2.ListRecordsResponse, error)

ListLogs Functionality not supported now

func (*RESTClient) ListRecords

func (c *RESTClient) ListRecords(ctx context.Context, in *v1alpha2.ListRecordsRequest, _ ...grpc.CallOption) (*v1alpha2.ListRecordsResponse, error)

ListRecords makes request to get record list

func (*RESTClient) ListResults

func (c *RESTClient) ListResults(ctx context.Context, in *v1alpha2.ListResultsRequest, _ ...grpc.CallOption) (*v1alpha2.ListResultsResponse, error)

ListResults makes request and get result list

func (*RESTClient) UpdateLog

func (c *RESTClient) UpdateLog(_ context.Context, _ ...grpc.CallOption) (v1alpha2.Logs_UpdateLogClient, error)

func (*RESTClient) UpdateRecord

func (c *RESTClient) UpdateRecord(_ context.Context, _ *v1alpha2.UpdateRecordRequest, _ ...grpc.CallOption) (*v1alpha2.Record, error)

func (*RESTClient) UpdateResult

func (c *RESTClient) UpdateResult(_ context.Context, _ *v1alpha2.UpdateResultRequest, _ ...grpc.CallOption) (*v1alpha2.Result, error)