proto

package
v0.15.2-rc.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 9, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Orchestrator_Connect_FullMethodName                              = "/proto.Orchestrator/Connect"
	Orchestrator_RegisterTriggerAgent_FullMethodName                 = "/proto.Orchestrator/RegisterTriggerAgent"
	Orchestrator_SendTriggerResult_FullMethodName                    = "/proto.Orchestrator/SendTriggerResult"
	Orchestrator_RegisterPollerAgent_FullMethodName                  = "/proto.Orchestrator/RegisterPollerAgent"
	Orchestrator_SendPolledSpans_FullMethodName                      = "/proto.Orchestrator/SendPolledSpans"
	Orchestrator_RegisterShutdownListener_FullMethodName             = "/proto.Orchestrator/RegisterShutdownListener"
	Orchestrator_Ping_FullMethodName                                 = "/proto.Orchestrator/Ping"
	Orchestrator_RegisterDataStoreConnectionTestAgent_FullMethodName = "/proto.Orchestrator/RegisterDataStoreConnectionTestAgent"
	Orchestrator_SendDataStoreConnectionTestResult_FullMethodName    = "/proto.Orchestrator/SendDataStoreConnectionTestResult"
)

Variables

View Source 
var File_proto_orchestrator_proto protoreflect.FileDescriptor
View Source 
var Orchestrator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Orchestrator",
	HandlerType: (*OrchestratorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Connect",
			Handler:    _Orchestrator_Connect_Handler,
		},
		{
			MethodName: "SendTriggerResult",
			Handler:    _Orchestrator_SendTriggerResult_Handler,
		},
		{
			MethodName: "SendPolledSpans",
			Handler:    _Orchestrator_SendPolledSpans_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _Orchestrator_Ping_Handler,
		},
		{
			MethodName: "SendDataStoreConnectionTestResult",
			Handler:    _Orchestrator_SendDataStoreConnectionTestResult_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RegisterTriggerAgent",
			Handler:       _Orchestrator_RegisterTriggerAgent_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RegisterPollerAgent",
			Handler:       _Orchestrator_RegisterPollerAgent_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RegisterShutdownListener",
			Handler:       _Orchestrator_RegisterShutdownListener_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "RegisterDataStoreConnectionTestAgent",
			Handler:       _Orchestrator_RegisterDataStoreConnectionTestAgent_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "proto/orchestrator.proto",
}

Orchestrator_ServiceDesc is the grpc.ServiceDesc for Orchestrator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOrchestratorServer 

func RegisterOrchestratorServer(s grpc.ServiceRegistrar, srv OrchestratorServer)

Types

type AgentConfiguration 

type AgentConfiguration struct {
	Configuration  *SessionConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	Identification *AgentIdentification  `protobuf:"bytes,2,opt,name=identification,proto3" json:"identification,omitempty"`
	// contains filtered or unexported fields
}

ConnectResponse is the Orchestrator response to the ConnectRequest. It contains configuration that must be used by the agent while working with this Orchestrator.

func (*AgentConfiguration) Descriptor deprecated 

func (*AgentConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use AgentConfiguration.ProtoReflect.Descriptor instead.

func (*AgentConfiguration) GetConfiguration 

func (x *AgentConfiguration) GetConfiguration() *SessionConfiguration

func (*AgentConfiguration) GetIdentification 

func (x *AgentConfiguration) GetIdentification() *AgentIdentification

func (*AgentConfiguration) ProtoMessage 

func (*AgentConfiguration) ProtoMessage()

func (*AgentConfiguration) ProtoReflect 

func (x *AgentConfiguration) ProtoReflect() protoreflect.Message

func (*AgentConfiguration) Reset 

func (x *AgentConfiguration) Reset()

func (*AgentConfiguration) String 

func (x *AgentConfiguration) String() string

type AgentIdentification 

type AgentIdentification struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

AgentIdentification contains data used by the server to validate an agent identity

func (*AgentIdentification) Descriptor deprecated 

func (*AgentIdentification) Descriptor() ([]byte, []int)

Deprecated: Use AgentIdentification.ProtoReflect.Descriptor instead.

func (*AgentIdentification) GetToken 

func (x *AgentIdentification) GetToken() string

func (*AgentIdentification) ProtoMessage 

func (*AgentIdentification) ProtoMessage()

func (*AgentIdentification) ProtoReflect 

func (x *AgentIdentification) ProtoReflect() protoreflect.Message

func (*AgentIdentification) Reset 

func (x *AgentIdentification) Reset()

func (*AgentIdentification) String 

func (x *AgentIdentification) String() string

type ApiKeyAuthentication 

type ApiKeyAuthentication struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	In    string `protobuf:"bytes,3,opt,name=in,proto3" json:"in,omitempty"`
	// contains filtered or unexported fields
}

func (*ApiKeyAuthentication) Descriptor deprecated 

func (*ApiKeyAuthentication) Descriptor() ([]byte, []int)

Deprecated: Use ApiKeyAuthentication.ProtoReflect.Descriptor instead.

func (*ApiKeyAuthentication) GetIn 

func (x *ApiKeyAuthentication) GetIn() string

func (*ApiKeyAuthentication) GetKey 

func (x *ApiKeyAuthentication) GetKey() string

func (*ApiKeyAuthentication) GetValue 

func (x *ApiKeyAuthentication) GetValue() string

func (*ApiKeyAuthentication) ProtoMessage 

func (*ApiKeyAuthentication) ProtoMessage()

func (*ApiKeyAuthentication) ProtoReflect 

func (x *ApiKeyAuthentication) ProtoReflect() protoreflect.Message

func (*ApiKeyAuthentication) Reset 

func (x *ApiKeyAuthentication) Reset()

func (*ApiKeyAuthentication) String 

func (x *ApiKeyAuthentication) String() string

type AwsXRayConfig 

type AwsXRayConfig struct {
	Region          string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	AccessKeyId     string `protobuf:"bytes,2,opt,name=accessKeyId,proto3" json:"accessKeyId,omitempty"`
	SecretAccessKey string `protobuf:"bytes,3,opt,name=secretAccessKey,proto3" json:"secretAccessKey,omitempty"`
	SessionToken    string `protobuf:"bytes,4,opt,name=sessionToken,proto3" json:"sessionToken,omitempty"`
	UseDefaultAuth  bool   `protobuf:"varint,5,opt,name=useDefaultAuth,proto3" json:"useDefaultAuth,omitempty"`
	// contains filtered or unexported fields
}

func (*AwsXRayConfig) Descriptor deprecated 

func (*AwsXRayConfig) Descriptor() ([]byte, []int)

Deprecated: Use AwsXRayConfig.ProtoReflect.Descriptor instead.

func (*AwsXRayConfig) GetAccessKeyId 

func (x *AwsXRayConfig) GetAccessKeyId() string

func (*AwsXRayConfig) GetRegion 

func (x *AwsXRayConfig) GetRegion() string

func (*AwsXRayConfig) GetSecretAccessKey 

func (x *AwsXRayConfig) GetSecretAccessKey() string

func (*AwsXRayConfig) GetSessionToken 

func (x *AwsXRayConfig) GetSessionToken() string

func (*AwsXRayConfig) GetUseDefaultAuth 

func (x *AwsXRayConfig) GetUseDefaultAuth() bool

func (*AwsXRayConfig) ProtoMessage 

func (*AwsXRayConfig) ProtoMessage()

func (*AwsXRayConfig) ProtoReflect 

func (x *AwsXRayConfig) ProtoReflect() protoreflect.Message

func (*AwsXRayConfig) Reset 

func (x *AwsXRayConfig) Reset()

func (*AwsXRayConfig) String 

func (x *AwsXRayConfig) String() string

type AzureAppInsightsConfig 

type AzureAppInsightsConfig struct {
	UseAzureActiveDirectoryAuth bool   `protobuf:"varint,1,opt,name=useAzureActiveDirectoryAuth,proto3" json:"useAzureActiveDirectoryAuth,omitempty"`
	AccessToken                 string `protobuf:"bytes,2,opt,name=accessToken,proto3" json:"accessToken,omitempty"`
	ConnectionType              string `protobuf:"bytes,3,opt,name=connectionType,proto3" json:"connectionType,omitempty"`
	ResourceArmId               string `protobuf:"bytes,4,opt,name=resourceArmId,proto3" json:"resourceArmId,omitempty"`
	// contains filtered or unexported fields
}

func (*AzureAppInsightsConfig) Descriptor deprecated 

func (*AzureAppInsightsConfig) Descriptor() ([]byte, []int)

Deprecated: Use AzureAppInsightsConfig.ProtoReflect.Descriptor instead.

func (*AzureAppInsightsConfig) GetAccessToken 

func (x *AzureAppInsightsConfig) GetAccessToken() string

func (*AzureAppInsightsConfig) GetConnectionType 

func (x *AzureAppInsightsConfig) GetConnectionType() string

func (*AzureAppInsightsConfig) GetResourceArmId 

func (x *AzureAppInsightsConfig) GetResourceArmId() string

func (*AzureAppInsightsConfig) GetUseAzureActiveDirectoryAuth 

func (x *AzureAppInsightsConfig) GetUseAzureActiveDirectoryAuth() bool

func (*AzureAppInsightsConfig) ProtoMessage 

func (*AzureAppInsightsConfig) ProtoMessage()

func (*AzureAppInsightsConfig) ProtoReflect 

func (x *AzureAppInsightsConfig) ProtoReflect() protoreflect.Message

func (*AzureAppInsightsConfig) Reset 

func (x *AzureAppInsightsConfig) Reset()

func (*AzureAppInsightsConfig) String 

func (x *AzureAppInsightsConfig) String() string

type BasicAuthentication 

type BasicAuthentication struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*BasicAuthentication) Descriptor deprecated 

func (*BasicAuthentication) Descriptor() ([]byte, []int)

Deprecated: Use BasicAuthentication.ProtoReflect.Descriptor instead.

func (*BasicAuthentication) GetPassword 

func (x *BasicAuthentication) GetPassword() string

func (*BasicAuthentication) GetUsername 

func (x *BasicAuthentication) GetUsername() string

func (*BasicAuthentication) ProtoMessage 

func (*BasicAuthentication) ProtoMessage()

func (*BasicAuthentication) ProtoReflect 

func (x *BasicAuthentication) ProtoReflect() protoreflect.Message

func (*BasicAuthentication) Reset 

func (x *BasicAuthentication) Reset()

func (*BasicAuthentication) String 

func (x *BasicAuthentication) String() string

type BearerAuthentication 

type BearerAuthentication struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*BearerAuthentication) Descriptor deprecated 

func (*BearerAuthentication) Descriptor() ([]byte, []int)

Deprecated: Use BearerAuthentication.ProtoReflect.Descriptor instead.

func (*BearerAuthentication) GetToken 

func (x *BearerAuthentication) GetToken() string

func (*BearerAuthentication) ProtoMessage 

func (*BearerAuthentication) ProtoMessage()

func (*BearerAuthentication) ProtoReflect 

func (x *BearerAuthentication) ProtoReflect() protoreflect.Message

func (*BearerAuthentication) Reset 

func (x *BearerAuthentication) Reset()

func (*BearerAuthentication) String 

func (x *BearerAuthentication) String() string

type ConnectRequest 

type ConnectRequest struct {
	ApiKey string `protobuf:"bytes,1,opt,name=apiKey,proto3" json:"apiKey,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

ConnectRequest is the initial request sent by the agent to the orchestrator it contains all necessary information for authentication and identification of the agent. An established connection is called a "session".

func (*ConnectRequest) Descriptor deprecated 

func (*ConnectRequest) Descriptor() ([]byte, []int)

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetApiKey 

func (x *ConnectRequest) GetApiKey() string

func (*ConnectRequest) GetName 

func (x *ConnectRequest) GetName() string

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

func (x *ConnectRequest) ProtoReflect() protoreflect.Message

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type DataStore 

type DataStore struct {
	Type             string                  `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Jaeger           *JaegerConfig           `protobuf:"bytes,2,opt,name=jaeger,proto3" json:"jaeger,omitempty"`
	Tempo            *TempoConfig            `protobuf:"bytes,3,opt,name=tempo,proto3" json:"tempo,omitempty"`
	Opensearch       *ElasticConfig          `protobuf:"bytes,4,opt,name=opensearch,proto3" json:"opensearch,omitempty"`
	Elasticapm       *ElasticConfig          `protobuf:"bytes,5,opt,name=elasticapm,proto3" json:"elasticapm,omitempty"`
	Signalfx         *SignalfxConfig         `protobuf:"bytes,6,opt,name=signalfx,proto3" json:"signalfx,omitempty"`
	Awsxray          *AwsXRayConfig          `protobuf:"bytes,7,opt,name=awsxray,proto3" json:"awsxray,omitempty"`
	Azureappinsights *AzureAppInsightsConfig `protobuf:"bytes,8,opt,name=azureappinsights,proto3" json:"azureappinsights,omitempty"`
	Sumologic        *SumoLogicConfig        `protobuf:"bytes,9,opt,name=sumologic,proto3" json:"sumologic,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStore) Descriptor deprecated 

func (*DataStore) Descriptor() ([]byte, []int)

Deprecated: Use DataStore.ProtoReflect.Descriptor instead.

func (*DataStore) GetAwsxray 

func (x *DataStore) GetAwsxray() *AwsXRayConfig

func (*DataStore) GetAzureappinsights 

func (x *DataStore) GetAzureappinsights() *AzureAppInsightsConfig

func (*DataStore) GetElasticapm 

func (x *DataStore) GetElasticapm() *ElasticConfig

func (*DataStore) GetJaeger 

func (x *DataStore) GetJaeger() *JaegerConfig

func (*DataStore) GetOpensearch 

func (x *DataStore) GetOpensearch() *ElasticConfig

func (*DataStore) GetSignalfx 

func (x *DataStore) GetSignalfx() *SignalfxConfig

func (*DataStore) GetSumologic added in v0.15.1 

func (x *DataStore) GetSumologic() *SumoLogicConfig

func (*DataStore) GetTempo 

func (x *DataStore) GetTempo() *TempoConfig

func (*DataStore) GetType 

func (x *DataStore) GetType() string

func (*DataStore) ProtoMessage 

func (*DataStore) ProtoMessage()

func (*DataStore) ProtoReflect 

func (x *DataStore) ProtoReflect() protoreflect.Message

func (*DataStore) Reset 

func (x *DataStore) Reset()

func (*DataStore) String 

func (x *DataStore) String() string

type DataStoreConnectionTestRequest 

type DataStoreConnectionTestRequest struct {
	RequestID string     `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"`
	Datastore *DataStore `protobuf:"bytes,2,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStoreConnectionTestRequest) Descriptor deprecated 

func (*DataStoreConnectionTestRequest) Descriptor() ([]byte, []int)

Deprecated: Use DataStoreConnectionTestRequest.ProtoReflect.Descriptor instead.

func (*DataStoreConnectionTestRequest) GetDatastore 

func (x *DataStoreConnectionTestRequest) GetDatastore() *DataStore

func (*DataStoreConnectionTestRequest) GetRequestID 

func (x *DataStoreConnectionTestRequest) GetRequestID() string

func (*DataStoreConnectionTestRequest) ProtoMessage 

func (*DataStoreConnectionTestRequest) ProtoMessage()

func (*DataStoreConnectionTestRequest) ProtoReflect 

func (x *DataStoreConnectionTestRequest) ProtoReflect() protoreflect.Message

func (*DataStoreConnectionTestRequest) Reset 

func (x *DataStoreConnectionTestRequest) Reset()

func (*DataStoreConnectionTestRequest) String 

func (x *DataStoreConnectionTestRequest) String() string

type DataStoreConnectionTestResponse 

type DataStoreConnectionTestResponse struct {
	RequestID           string                        `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"`
	Successful          bool                          `protobuf:"varint,2,opt,name=successful,proto3" json:"successful,omitempty"`
	AgentIdentification *AgentIdentification          `protobuf:"bytes,3,opt,name=agentIdentification,proto3" json:"agentIdentification,omitempty"`
	Steps               *DataStoreConnectionTestSteps `protobuf:"bytes,4,opt,name=steps,proto3" json:"steps,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStoreConnectionTestResponse) Descriptor deprecated 

func (*DataStoreConnectionTestResponse) Descriptor() ([]byte, []int)

Deprecated: Use DataStoreConnectionTestResponse.ProtoReflect.Descriptor instead.

func (*DataStoreConnectionTestResponse) GetAgentIdentification 

func (x *DataStoreConnectionTestResponse) GetAgentIdentification() *AgentIdentification

func (*DataStoreConnectionTestResponse) GetRequestID 

func (x *DataStoreConnectionTestResponse) GetRequestID() string

func (*DataStoreConnectionTestResponse) GetSteps 

func (x *DataStoreConnectionTestResponse) GetSteps() *DataStoreConnectionTestSteps

func (*DataStoreConnectionTestResponse) GetSuccessful 

func (x *DataStoreConnectionTestResponse) GetSuccessful() bool

func (*DataStoreConnectionTestResponse) ProtoMessage 

func (*DataStoreConnectionTestResponse) ProtoMessage()

func (*DataStoreConnectionTestResponse) ProtoReflect 

func (x *DataStoreConnectionTestResponse) ProtoReflect() protoreflect.Message

func (*DataStoreConnectionTestResponse) Reset 

func (x *DataStoreConnectionTestResponse) Reset()

func (*DataStoreConnectionTestResponse) String 

func (x *DataStoreConnectionTestResponse) String() string

type DataStoreConnectionTestStep 

type DataStoreConnectionTestStep struct {
	Passed  bool   `protobuf:"varint,1,opt,name=passed,proto3" json:"passed,omitempty"`
	Status  string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Error   string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStoreConnectionTestStep) Descriptor deprecated 

func (*DataStoreConnectionTestStep) Descriptor() ([]byte, []int)

Deprecated: Use DataStoreConnectionTestStep.ProtoReflect.Descriptor instead.

func (*DataStoreConnectionTestStep) GetError 

func (x *DataStoreConnectionTestStep) GetError() string

func (*DataStoreConnectionTestStep) GetMessage 

func (x *DataStoreConnectionTestStep) GetMessage() string

func (*DataStoreConnectionTestStep) GetPassed 

func (x *DataStoreConnectionTestStep) GetPassed() bool

func (*DataStoreConnectionTestStep) GetStatus 

func (x *DataStoreConnectionTestStep) GetStatus() string

func (*DataStoreConnectionTestStep) ProtoMessage 

func (*DataStoreConnectionTestStep) ProtoMessage()

func (*DataStoreConnectionTestStep) ProtoReflect 

func (x *DataStoreConnectionTestStep) ProtoReflect() protoreflect.Message

func (*DataStoreConnectionTestStep) Reset 

func (x *DataStoreConnectionTestStep) Reset()

func (*DataStoreConnectionTestStep) String 

func (x *DataStoreConnectionTestStep) String() string

type DataStoreConnectionTestSteps 

type DataStoreConnectionTestSteps struct {
	PortCheck      *DataStoreConnectionTestStep `protobuf:"bytes,1,opt,name=portCheck,proto3" json:"portCheck,omitempty"`
	Connectivity   *DataStoreConnectionTestStep `protobuf:"bytes,2,opt,name=connectivity,proto3" json:"connectivity,omitempty"`
	Authentication *DataStoreConnectionTestStep `protobuf:"bytes,3,opt,name=authentication,proto3" json:"authentication,omitempty"`
	FetchTraces    *DataStoreConnectionTestStep `protobuf:"bytes,4,opt,name=fetchTraces,proto3" json:"fetchTraces,omitempty"`
	// contains filtered or unexported fields
}

func (*DataStoreConnectionTestSteps) Descriptor deprecated 

func (*DataStoreConnectionTestSteps) Descriptor() ([]byte, []int)

Deprecated: Use DataStoreConnectionTestSteps.ProtoReflect.Descriptor instead.

func (*DataStoreConnectionTestSteps) GetAuthentication 

func (x *DataStoreConnectionTestSteps) GetAuthentication() *DataStoreConnectionTestStep

func (*DataStoreConnectionTestSteps) GetConnectivity 

func (x *DataStoreConnectionTestSteps) GetConnectivity() *DataStoreConnectionTestStep

func (*DataStoreConnectionTestSteps) GetFetchTraces 

func (x *DataStoreConnectionTestSteps) GetFetchTraces() *DataStoreConnectionTestStep

func (*DataStoreConnectionTestSteps) GetPortCheck 

func (x *DataStoreConnectionTestSteps) GetPortCheck() *DataStoreConnectionTestStep

func (*DataStoreConnectionTestSteps) ProtoMessage 

func (*DataStoreConnectionTestSteps) ProtoMessage()

func (*DataStoreConnectionTestSteps) ProtoReflect 

func (x *DataStoreConnectionTestSteps) ProtoReflect() protoreflect.Message

func (*DataStoreConnectionTestSteps) Reset 

func (x *DataStoreConnectionTestSteps) Reset()

func (*DataStoreConnectionTestSteps) String 

func (x *DataStoreConnectionTestSteps) String() string

type ElasticConfig 

type ElasticConfig struct {
	Addresses          []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	Username           string   `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Password           string   `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Index              string   `protobuf:"bytes,4,opt,name=index,proto3" json:"index,omitempty"`
	Certificate        string   `protobuf:"bytes,5,opt,name=certificate,proto3" json:"certificate,omitempty"`
	InsecureSkipVerify bool     `protobuf:"varint,6,opt,name=insecureSkipVerify,proto3" json:"insecureSkipVerify,omitempty"`
	// contains filtered or unexported fields
}

func (*ElasticConfig) Descriptor deprecated 

func (*ElasticConfig) Descriptor() ([]byte, []int)

Deprecated: Use ElasticConfig.ProtoReflect.Descriptor instead.

func (*ElasticConfig) GetAddresses 

func (x *ElasticConfig) GetAddresses() []string

func (*ElasticConfig) GetCertificate 

func (x *ElasticConfig) GetCertificate() string

func (*ElasticConfig) GetIndex 

func (x *ElasticConfig) GetIndex() string

func (*ElasticConfig) GetInsecureSkipVerify 

func (x *ElasticConfig) GetInsecureSkipVerify() bool

func (*ElasticConfig) GetPassword 

func (x *ElasticConfig) GetPassword() string

func (*ElasticConfig) GetUsername 

func (x *ElasticConfig) GetUsername() string

func (*ElasticConfig) ProtoMessage 

func (*ElasticConfig) ProtoMessage()

func (*ElasticConfig) ProtoReflect 

func (x *ElasticConfig) ProtoReflect() protoreflect.Message

func (*ElasticConfig) Reset 

func (x *ElasticConfig) Reset()

func (*ElasticConfig) String 

func (x *ElasticConfig) String() string

type Empty 

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

Empty message for endpoints that don't return anything

func (*Empty) Descriptor deprecated 

func (*Empty) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type Error added in v0.14.6 

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated added in v0.14.6 

func (*Error) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetMessage added in v0.14.6 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage added in v0.14.6 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect added in v0.14.6 

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset added in v0.14.6 

func (x *Error) Reset()

func (*Error) String added in v0.14.6 

func (x *Error) String() string

type GrpcClientSettings 

type GrpcClientSettings struct {
	Endpoint        string              `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	ReadBufferSize  int64               `protobuf:"varint,2,opt,name=readBufferSize,proto3" json:"readBufferSize,omitempty"`
	WriteBufferSize int64               `protobuf:"varint,3,opt,name=writeBufferSize,proto3" json:"writeBufferSize,omitempty"`
	WaitForReady    bool                `protobuf:"varint,4,opt,name=waitForReady,proto3" json:"waitForReady,omitempty"`
	Headers         *HttpHeader         `protobuf:"bytes,5,opt,name=headers,proto3" json:"headers,omitempty"`
	BalancerName    string              `protobuf:"bytes,6,opt,name=balancerName,proto3" json:"balancerName,omitempty"`
	Compression     string              `protobuf:"bytes,7,opt,name=compression,proto3" json:"compression,omitempty"`
	Tls             *TLS                `protobuf:"bytes,8,opt,name=tls,proto3" json:"tls,omitempty"`
	Auth            *HttpAuthentication `protobuf:"bytes,9,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcClientSettings) Descriptor deprecated 

func (*GrpcClientSettings) Descriptor() ([]byte, []int)

Deprecated: Use GrpcClientSettings.ProtoReflect.Descriptor instead.

func (*GrpcClientSettings) GetAuth 

func (x *GrpcClientSettings) GetAuth() *HttpAuthentication

func (*GrpcClientSettings) GetBalancerName 

func (x *GrpcClientSettings) GetBalancerName() string

func (*GrpcClientSettings) GetCompression 

func (x *GrpcClientSettings) GetCompression() string

func (*GrpcClientSettings) GetEndpoint 

func (x *GrpcClientSettings) GetEndpoint() string

func (*GrpcClientSettings) GetHeaders 

func (x *GrpcClientSettings) GetHeaders() *HttpHeader

func (*GrpcClientSettings) GetReadBufferSize 

func (x *GrpcClientSettings) GetReadBufferSize() int64

func (*GrpcClientSettings) GetTls 

func (x *GrpcClientSettings) GetTls() *TLS

func (*GrpcClientSettings) GetWaitForReady 

func (x *GrpcClientSettings) GetWaitForReady() bool

func (*GrpcClientSettings) GetWriteBufferSize 

func (x *GrpcClientSettings) GetWriteBufferSize() int64

func (*GrpcClientSettings) ProtoMessage 

func (*GrpcClientSettings) ProtoMessage()

func (*GrpcClientSettings) ProtoReflect 

func (x *GrpcClientSettings) ProtoReflect() protoreflect.Message

func (*GrpcClientSettings) Reset 

func (x *GrpcClientSettings) Reset()

func (*GrpcClientSettings) String 

func (x *GrpcClientSettings) String() string

type GrpcHeader 

type GrpcHeader struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcHeader) Descriptor deprecated 

func (*GrpcHeader) Descriptor() ([]byte, []int)

Deprecated: Use GrpcHeader.ProtoReflect.Descriptor instead.

func (*GrpcHeader) GetKey 

func (x *GrpcHeader) GetKey() string

func (*GrpcHeader) GetValue 

func (x *GrpcHeader) GetValue() string

func (*GrpcHeader) ProtoMessage 

func (*GrpcHeader) ProtoMessage()

func (*GrpcHeader) ProtoReflect 

func (x *GrpcHeader) ProtoReflect() protoreflect.Message

func (*GrpcHeader) Reset 

func (x *GrpcHeader) Reset()

func (*GrpcHeader) String 

func (x *GrpcHeader) String() string

type GrpcRequest 

type GrpcRequest struct {
	ProtobufFile   string              `protobuf:"bytes,1,opt,name=protobufFile,proto3" json:"protobufFile,omitempty"`
	Address        string              `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Service        string              `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	Method         string              `protobuf:"bytes,4,opt,name=method,proto3" json:"method,omitempty"`
	Request        string              `protobuf:"bytes,5,opt,name=request,proto3" json:"request,omitempty"`
	Authentication *HttpAuthentication `protobuf:"bytes,6,opt,name=authentication,proto3" json:"authentication,omitempty"`
	Metadata       []*GrpcHeader       `protobuf:"bytes,7,rep,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcRequest) Descriptor deprecated 

func (*GrpcRequest) Descriptor() ([]byte, []int)

Deprecated: Use GrpcRequest.ProtoReflect.Descriptor instead.

func (*GrpcRequest) GetAddress 

func (x *GrpcRequest) GetAddress() string

func (*GrpcRequest) GetAuthentication 

func (x *GrpcRequest) GetAuthentication() *HttpAuthentication

func (*GrpcRequest) GetMetadata 

func (x *GrpcRequest) GetMetadata() []*GrpcHeader

func (*GrpcRequest) GetMethod 

func (x *GrpcRequest) GetMethod() string

func (*GrpcRequest) GetProtobufFile 

func (x *GrpcRequest) GetProtobufFile() string

func (*GrpcRequest) GetRequest 

func (x *GrpcRequest) GetRequest() string

func (*GrpcRequest) GetService 

func (x *GrpcRequest) GetService() string

func (*GrpcRequest) ProtoMessage 

func (*GrpcRequest) ProtoMessage()

func (*GrpcRequest) ProtoReflect 

func (x *GrpcRequest) ProtoReflect() protoreflect.Message

func (*GrpcRequest) Reset 

func (x *GrpcRequest) Reset()

func (*GrpcRequest) String 

func (x *GrpcRequest) String() string

type GrpcResponse 

type GrpcResponse struct {
	StatusCode int32         `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Metadata   []*GrpcHeader `protobuf:"bytes,2,rep,name=metadata,proto3" json:"metadata,omitempty"`
	Body       []byte        `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*GrpcResponse) Descriptor deprecated 

func (*GrpcResponse) Descriptor() ([]byte, []int)

Deprecated: Use GrpcResponse.ProtoReflect.Descriptor instead.

func (*GrpcResponse) GetBody 

func (x *GrpcResponse) GetBody() []byte

func (*GrpcResponse) GetMetadata 

func (x *GrpcResponse) GetMetadata() []*GrpcHeader

func (*GrpcResponse) GetStatusCode 

func (x *GrpcResponse) GetStatusCode() int32

func (*GrpcResponse) ProtoMessage 

func (*GrpcResponse) ProtoMessage()

func (*GrpcResponse) ProtoReflect 

func (x *GrpcResponse) ProtoReflect() protoreflect.Message

func (*GrpcResponse) Reset 

func (x *GrpcResponse) Reset()

func (*GrpcResponse) String 

func (x *GrpcResponse) String() string

type HttpAuthentication 

type HttpAuthentication struct {
	Type   string                `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	ApiKey *ApiKeyAuthentication `protobuf:"bytes,2,opt,name=apiKey,proto3" json:"apiKey,omitempty"`
	Basic  *BasicAuthentication  `protobuf:"bytes,3,opt,name=basic,proto3" json:"basic,omitempty"`
	Bearer *BearerAuthentication `protobuf:"bytes,4,opt,name=bearer,proto3" json:"bearer,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpAuthentication) Descriptor deprecated 

func (*HttpAuthentication) Descriptor() ([]byte, []int)

Deprecated: Use HttpAuthentication.ProtoReflect.Descriptor instead.

func (*HttpAuthentication) GetApiKey 

func (x *HttpAuthentication) GetApiKey() *ApiKeyAuthentication

func (*HttpAuthentication) GetBasic 

func (x *HttpAuthentication) GetBasic() *BasicAuthentication

func (*HttpAuthentication) GetBearer 

func (x *HttpAuthentication) GetBearer() *BearerAuthentication

func (*HttpAuthentication) GetType 

func (x *HttpAuthentication) GetType() string

func (*HttpAuthentication) ProtoMessage 

func (*HttpAuthentication) ProtoMessage()

func (*HttpAuthentication) ProtoReflect 

func (x *HttpAuthentication) ProtoReflect() protoreflect.Message

func (*HttpAuthentication) Reset 

func (x *HttpAuthentication) Reset()

func (*HttpAuthentication) String 

func (x *HttpAuthentication) String() string

type HttpClientSettings 

type HttpClientSettings struct {
	Url            string              `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Headers        []*HttpHeader       `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	Tls            *TLS                `protobuf:"bytes,3,opt,name=tls,proto3" json:"tls,omitempty"`
	Authentication *HttpAuthentication `protobuf:"bytes,4,opt,name=authentication,proto3" json:"authentication,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpClientSettings) Descriptor deprecated 

func (*HttpClientSettings) Descriptor() ([]byte, []int)

Deprecated: Use HttpClientSettings.ProtoReflect.Descriptor instead.

func (*HttpClientSettings) GetAuthentication 

func (x *HttpClientSettings) GetAuthentication() *HttpAuthentication

func (*HttpClientSettings) GetHeaders 

func (x *HttpClientSettings) GetHeaders() []*HttpHeader

func (*HttpClientSettings) GetTls 

func (x *HttpClientSettings) GetTls() *TLS

func (*HttpClientSettings) GetUrl 

func (x *HttpClientSettings) GetUrl() string

func (*HttpClientSettings) ProtoMessage 

func (*HttpClientSettings) ProtoMessage()

func (*HttpClientSettings) ProtoReflect 

func (x *HttpClientSettings) ProtoReflect() protoreflect.Message

func (*HttpClientSettings) Reset 

func (x *HttpClientSettings) Reset()

func (*HttpClientSettings) String 

func (x *HttpClientSettings) String() string

type HttpHeader 

type HttpHeader struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpHeader) Descriptor deprecated 

func (*HttpHeader) Descriptor() ([]byte, []int)

Deprecated: Use HttpHeader.ProtoReflect.Descriptor instead.

func (*HttpHeader) GetKey 

func (x *HttpHeader) GetKey() string

func (*HttpHeader) GetValue 

func (x *HttpHeader) GetValue() string

func (*HttpHeader) ProtoMessage 

func (*HttpHeader) ProtoMessage()

func (*HttpHeader) ProtoReflect 

func (x *HttpHeader) ProtoReflect() protoreflect.Message

func (*HttpHeader) Reset 

func (x *HttpHeader) Reset()

func (*HttpHeader) String 

func (x *HttpHeader) String() string

type HttpRequest 

type HttpRequest struct {
	Method          string              `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Url             string              `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Body            string              `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	Headers         []*HttpHeader       `protobuf:"bytes,4,rep,name=headers,proto3" json:"headers,omitempty"`
	Authentication  *HttpAuthentication `protobuf:"bytes,5,opt,name=authentication,proto3" json:"authentication,omitempty"`
	SSLVerification bool                `protobuf:"varint,6,opt,name=SSLVerification,proto3" json:"SSLVerification,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpRequest) Descriptor deprecated 

func (*HttpRequest) Descriptor() ([]byte, []int)

Deprecated: Use HttpRequest.ProtoReflect.Descriptor instead.

func (*HttpRequest) GetAuthentication 

func (x *HttpRequest) GetAuthentication() *HttpAuthentication

func (*HttpRequest) GetBody 

func (x *HttpRequest) GetBody() string

func (*HttpRequest) GetHeaders 

func (x *HttpRequest) GetHeaders() []*HttpHeader

func (*HttpRequest) GetMethod 

func (x *HttpRequest) GetMethod() string

func (*HttpRequest) GetSSLVerification 

func (x *HttpRequest) GetSSLVerification() bool

func (*HttpRequest) GetUrl 

func (x *HttpRequest) GetUrl() string

func (*HttpRequest) ProtoMessage 

func (*HttpRequest) ProtoMessage()

func (*HttpRequest) ProtoReflect 

func (x *HttpRequest) ProtoReflect() protoreflect.Message

func (*HttpRequest) Reset 

func (x *HttpRequest) Reset()

func (*HttpRequest) String 

func (x *HttpRequest) String() string

type HttpResponse 

type HttpResponse struct {
	StatusCode int32         `protobuf:"varint,1,opt,name=statusCode,proto3" json:"statusCode,omitempty"`
	Status     string        `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Headers    []*HttpHeader `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	Body       []byte        `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*HttpResponse) Descriptor deprecated 

func (*HttpResponse) Descriptor() ([]byte, []int)

Deprecated: Use HttpResponse.ProtoReflect.Descriptor instead.

func (*HttpResponse) GetBody 

func (x *HttpResponse) GetBody() []byte

func (*HttpResponse) GetHeaders 

func (x *HttpResponse) GetHeaders() []*HttpHeader

func (*HttpResponse) GetStatus 

func (x *HttpResponse) GetStatus() string

func (*HttpResponse) GetStatusCode 

func (x *HttpResponse) GetStatusCode() int32

func (*HttpResponse) ProtoMessage 

func (*HttpResponse) ProtoMessage()

func (*HttpResponse) ProtoReflect 

func (x *HttpResponse) ProtoReflect() protoreflect.Message

func (*HttpResponse) Reset 

func (x *HttpResponse) Reset()

func (*HttpResponse) String 

func (x *HttpResponse) String() string

type JaegerConfig 

type JaegerConfig struct {
	Grpc *GrpcClientSettings `protobuf:"bytes,1,opt,name=grpc,proto3" json:"grpc,omitempty"`
	// contains filtered or unexported fields
}

func (*JaegerConfig) Descriptor deprecated 

func (*JaegerConfig) Descriptor() ([]byte, []int)

Deprecated: Use JaegerConfig.ProtoReflect.Descriptor instead.

func (*JaegerConfig) GetGrpc 

func (x *JaegerConfig) GetGrpc() *GrpcClientSettings

func (*JaegerConfig) ProtoMessage 

func (*JaegerConfig) ProtoMessage()

func (*JaegerConfig) ProtoReflect 

func (x *JaegerConfig) ProtoReflect() protoreflect.Message

func (*JaegerConfig) Reset 

func (x *JaegerConfig) Reset()

func (*JaegerConfig) String 

func (x *JaegerConfig) String() string

type KafkaAuthentication 

type KafkaAuthentication struct {
	Type  string                    `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Plain *KafkaPlainAuthentication `protobuf:"bytes,2,opt,name=plain,proto3" json:"plain,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaAuthentication) Descriptor deprecated 

func (*KafkaAuthentication) Descriptor() ([]byte, []int)

Deprecated: Use KafkaAuthentication.ProtoReflect.Descriptor instead.

func (*KafkaAuthentication) GetPlain 

func (x *KafkaAuthentication) GetPlain() *KafkaPlainAuthentication

func (*KafkaAuthentication) GetType 

func (x *KafkaAuthentication) GetType() string

func (*KafkaAuthentication) ProtoMessage 

func (*KafkaAuthentication) ProtoMessage()

func (*KafkaAuthentication) ProtoReflect 

func (x *KafkaAuthentication) ProtoReflect() protoreflect.Message

func (*KafkaAuthentication) Reset 

func (x *KafkaAuthentication) Reset()

func (*KafkaAuthentication) String 

func (x *KafkaAuthentication) String() string

type KafkaPlainAuthentication 

type KafkaPlainAuthentication struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaPlainAuthentication) Descriptor deprecated 

func (*KafkaPlainAuthentication) Descriptor() ([]byte, []int)

Deprecated: Use KafkaPlainAuthentication.ProtoReflect.Descriptor instead.

func (*KafkaPlainAuthentication) GetPassword 

func (x *KafkaPlainAuthentication) GetPassword() string

func (*KafkaPlainAuthentication) GetUsername 

func (x *KafkaPlainAuthentication) GetUsername() string

func (*KafkaPlainAuthentication) ProtoMessage 

func (*KafkaPlainAuthentication) ProtoMessage()

func (*KafkaPlainAuthentication) ProtoReflect 

func (x *KafkaPlainAuthentication) ProtoReflect() protoreflect.Message

func (*KafkaPlainAuthentication) Reset 

func (x *KafkaPlainAuthentication) Reset()

func (*KafkaPlainAuthentication) String 

func (x *KafkaPlainAuthentication) String() string

type KafkaRequest 

type KafkaRequest struct {
	BrokerUrls      []string             `protobuf:"bytes,1,rep,name=brokerUrls,proto3" json:"brokerUrls,omitempty"`
	Topic           string               `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Authentication  *KafkaAuthentication `protobuf:"bytes,3,opt,name=authentication,proto3" json:"authentication,omitempty"`
	SslVerification bool                 `protobuf:"varint,4,opt,name=sslVerification,proto3" json:"sslVerification,omitempty"`
	Headers         []*KeyValuePair      `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`
	MessageKey      string               `protobuf:"bytes,6,opt,name=messageKey,proto3" json:"messageKey,omitempty"`
	MessageValue    string               `protobuf:"bytes,7,opt,name=messageValue,proto3" json:"messageValue,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaRequest) Descriptor deprecated 

func (*KafkaRequest) Descriptor() ([]byte, []int)

Deprecated: Use KafkaRequest.ProtoReflect.Descriptor instead.

func (*KafkaRequest) GetAuthentication 

func (x *KafkaRequest) GetAuthentication() *KafkaAuthentication

func (*KafkaRequest) GetBrokerUrls 

func (x *KafkaRequest) GetBrokerUrls() []string

func (*KafkaRequest) GetHeaders 

func (x *KafkaRequest) GetHeaders() []*KeyValuePair

func (*KafkaRequest) GetMessageKey 

func (x *KafkaRequest) GetMessageKey() string

func (*KafkaRequest) GetMessageValue 

func (x *KafkaRequest) GetMessageValue() string

func (*KafkaRequest) GetSslVerification 

func (x *KafkaRequest) GetSslVerification() bool

func (*KafkaRequest) GetTopic 

func (x *KafkaRequest) GetTopic() string

func (*KafkaRequest) ProtoMessage 

func (*KafkaRequest) ProtoMessage()

func (*KafkaRequest) ProtoReflect 

func (x *KafkaRequest) ProtoReflect() protoreflect.Message

func (*KafkaRequest) Reset 

func (x *KafkaRequest) Reset()

func (*KafkaRequest) String 

func (x *KafkaRequest) String() string

type KafkaResponse 

type KafkaResponse struct {
	Partition string `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset    string `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaResponse) Descriptor deprecated 

func (*KafkaResponse) Descriptor() ([]byte, []int)

Deprecated: Use KafkaResponse.ProtoReflect.Descriptor instead.

func (*KafkaResponse) GetOffset 

func (x *KafkaResponse) GetOffset() string

func (*KafkaResponse) GetPartition 

func (x *KafkaResponse) GetPartition() string

func (*KafkaResponse) ProtoMessage 

func (*KafkaResponse) ProtoMessage()

func (*KafkaResponse) ProtoReflect 

func (x *KafkaResponse) ProtoReflect() protoreflect.Message

func (*KafkaResponse) Reset 

func (x *KafkaResponse) Reset()

func (*KafkaResponse) String 

func (x *KafkaResponse) String() string

type KeyValuePair 

type KeyValuePair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValuePair) Descriptor deprecated 

func (*KeyValuePair) Descriptor() ([]byte, []int)

Deprecated: Use KeyValuePair.ProtoReflect.Descriptor instead.

func (*KeyValuePair) GetKey 

func (x *KeyValuePair) GetKey() string

func (*KeyValuePair) GetValue 

func (x *KeyValuePair) GetValue() string

func (*KeyValuePair) ProtoMessage 

func (*KeyValuePair) ProtoMessage()

func (*KeyValuePair) ProtoReflect 

func (x *KeyValuePair) ProtoReflect() protoreflect.Message

func (*KeyValuePair) Reset 

func (x *KeyValuePair) Reset()

func (*KeyValuePair) String 

func (x *KeyValuePair) String() string

type OrchestratorClient 

type OrchestratorClient interface {
	// Connects an agent and returns the configuration that must be used by that agent
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*AgentConfiguration, error)
	// Register an agent as a trigger agent, once connected, the server will be able to send
	// multiple trigger requests to the agent.
	RegisterTriggerAgent(ctx context.Context, in *AgentIdentification, opts ...grpc.CallOption) (Orchestrator_RegisterTriggerAgentClient, error)
	// Sends the trigger result back to the server
	SendTriggerResult(ctx context.Context, in *TriggerResponse, opts ...grpc.CallOption) (*Empty, error)
	// Register an agent as a poller agent, once connected, the server will be able to send
	// multiple polling requests to the agent
	RegisterPollerAgent(ctx context.Context, in *AgentIdentification, opts ...grpc.CallOption) (Orchestrator_RegisterPollerAgentClient, error)
	// Sends polled spans to the server
	SendPolledSpans(ctx context.Context, in *PollingResponse, opts ...grpc.CallOption) (*Empty, error)
	// Register an agent to listen for shutdown commands
	RegisterShutdownListener(ctx context.Context, in *AgentIdentification, opts ...grpc.CallOption) (Orchestrator_RegisterShutdownListenerClient, error)
	// Ping is used to check if the agent is still connected
	Ping(ctx context.Context, in *AgentIdentification, opts ...grpc.CallOption) (*Empty, error)
	// Register an agent to listen for datastore connection test requests
	RegisterDataStoreConnectionTestAgent(ctx context.Context, in *AgentIdentification, opts ...grpc.CallOption) (Orchestrator_RegisterDataStoreConnectionTestAgentClient, error)
	// Sends datastore connection test result back to the server
	SendDataStoreConnectionTestResult(ctx context.Context, in *DataStoreConnectionTestResponse, opts ...grpc.CallOption) (*Empty, error)
}

OrchestratorClient is the client API for Orchestrator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOrchestratorClient 

func NewOrchestratorClient(cc grpc.ClientConnInterface) OrchestratorClient

type OrchestratorServer 

type OrchestratorServer interface {
	// Connects an agent and returns the configuration that must be used by that agent
	Connect(context.Context, *ConnectRequest) (*AgentConfiguration, error)
	// Register an agent as a trigger agent, once connected, the server will be able to send
	// multiple trigger requests to the agent.
	RegisterTriggerAgent(*AgentIdentification, Orchestrator_RegisterTriggerAgentServer) error
	// Sends the trigger result back to the server
	SendTriggerResult(context.Context, *TriggerResponse) (*Empty, error)
	// Register an agent as a poller agent, once connected, the server will be able to send
	// multiple polling requests to the agent
	RegisterPollerAgent(*AgentIdentification, Orchestrator_RegisterPollerAgentServer) error
	// Sends polled spans to the server
	SendPolledSpans(context.Context, *PollingResponse) (*Empty, error)
	// Register an agent to listen for shutdown commands
	RegisterShutdownListener(*AgentIdentification, Orchestrator_RegisterShutdownListenerServer) error
	// Ping is used to check if the agent is still connected
	Ping(context.Context, *AgentIdentification) (*Empty, error)
	// Register an agent to listen for datastore connection test requests
	RegisterDataStoreConnectionTestAgent(*AgentIdentification, Orchestrator_RegisterDataStoreConnectionTestAgentServer) error
	// Sends datastore connection test result back to the server
	SendDataStoreConnectionTestResult(context.Context, *DataStoreConnectionTestResponse) (*Empty, error)
	// contains filtered or unexported methods
}

OrchestratorServer is the server API for Orchestrator service. All implementations must embed UnimplementedOrchestratorServer for forward compatibility

type Orchestrator_RegisterDataStoreConnectionTestAgentClient 

type Orchestrator_RegisterDataStoreConnectionTestAgentClient interface {
	Recv() (*DataStoreConnectionTestRequest, error)
	grpc.ClientStream
}

type Orchestrator_RegisterDataStoreConnectionTestAgentServer 

type Orchestrator_RegisterDataStoreConnectionTestAgentServer interface {
	Send(*DataStoreConnectionTestRequest) error
	grpc.ServerStream
}

type Orchestrator_RegisterPollerAgentClient 

type Orchestrator_RegisterPollerAgentClient interface {
	Recv() (*PollingRequest, error)
	grpc.ClientStream
}

type Orchestrator_RegisterPollerAgentServer 

type Orchestrator_RegisterPollerAgentServer interface {
	Send(*PollingRequest) error
	grpc.ServerStream
}

type Orchestrator_RegisterShutdownListenerClient 

type Orchestrator_RegisterShutdownListenerClient interface {
	Recv() (*ShutdownRequest, error)
	grpc.ClientStream
}

type Orchestrator_RegisterShutdownListenerServer 

type Orchestrator_RegisterShutdownListenerServer interface {
	Send(*ShutdownRequest) error
	grpc.ServerStream
}

type Orchestrator_RegisterTriggerAgentClient 

type Orchestrator_RegisterTriggerAgentClient interface {
	Recv() (*TriggerRequest, error)
	grpc.ClientStream
}

type Orchestrator_RegisterTriggerAgentServer 

type Orchestrator_RegisterTriggerAgentServer interface {
	Send(*TriggerRequest) error
	grpc.ServerStream
}

type PollingRequest 

type PollingRequest struct {
	RequestID string     `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"`
	TestID    string     `protobuf:"bytes,2,opt,name=testID,proto3" json:"testID,omitempty"`
	RunID     int32      `protobuf:"varint,3,opt,name=runID,proto3" json:"runID,omitempty"`
	TraceID   string     `protobuf:"bytes,4,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Datastore *DataStore `protobuf:"bytes,5,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// contains filtered or unexported fields
}

func (*PollingRequest) Descriptor deprecated 

func (*PollingRequest) Descriptor() ([]byte, []int)

Deprecated: Use PollingRequest.ProtoReflect.Descriptor instead.

func (*PollingRequest) GetDatastore 

func (x *PollingRequest) GetDatastore() *DataStore

func (*PollingRequest) GetRequestID 

func (x *PollingRequest) GetRequestID() string

func (*PollingRequest) GetRunID 

func (x *PollingRequest) GetRunID() int32

func (*PollingRequest) GetTestID 

func (x *PollingRequest) GetTestID() string

func (*PollingRequest) GetTraceID 

func (x *PollingRequest) GetTraceID() string

func (*PollingRequest) ProtoMessage 

func (*PollingRequest) ProtoMessage()

func (*PollingRequest) ProtoReflect 

func (x *PollingRequest) ProtoReflect() protoreflect.Message

func (*PollingRequest) Reset 

func (x *PollingRequest) Reset()

func (*PollingRequest) String 

func (x *PollingRequest) String() string

type PollingResponse 

type PollingResponse struct {
	RequestID           string               `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"`
	AgentIdentification *AgentIdentification `protobuf:"bytes,2,opt,name=agentIdentification,proto3" json:"agentIdentification,omitempty"`
	TestID              string               `protobuf:"bytes,3,opt,name=testID,proto3" json:"testID,omitempty"`
	RunID               int32                `protobuf:"varint,4,opt,name=runID,proto3" json:"runID,omitempty"`
	TraceID             string               `protobuf:"bytes,5,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Spans               []*Span              `protobuf:"bytes,6,rep,name=spans,proto3" json:"spans,omitempty"`
	TraceFound          bool                 `protobuf:"varint,7,opt,name=traceFound,proto3" json:"traceFound,omitempty"`
	Error               *Error               `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*PollingResponse) Descriptor deprecated 

func (*PollingResponse) Descriptor() ([]byte, []int)

Deprecated: Use PollingResponse.ProtoReflect.Descriptor instead.

func (*PollingResponse) GetAgentIdentification 

func (x *PollingResponse) GetAgentIdentification() *AgentIdentification

func (*PollingResponse) GetError added in v0.14.6 

func (x *PollingResponse) GetError() *Error

func (*PollingResponse) GetRequestID 

func (x *PollingResponse) GetRequestID() string

func (*PollingResponse) GetRunID 

func (x *PollingResponse) GetRunID() int32

func (*PollingResponse) GetSpans 

func (x *PollingResponse) GetSpans() []*Span

func (*PollingResponse) GetTestID 

func (x *PollingResponse) GetTestID() string

func (*PollingResponse) GetTraceFound 

func (x *PollingResponse) GetTraceFound() bool

func (*PollingResponse) GetTraceID 

func (x *PollingResponse) GetTraceID() string

func (*PollingResponse) ProtoMessage 

func (*PollingResponse) ProtoMessage()

func (*PollingResponse) ProtoReflect 

func (x *PollingResponse) ProtoReflect() protoreflect.Message

func (*PollingResponse) Reset 

func (x *PollingResponse) Reset()

func (*PollingResponse) String 

func (x *PollingResponse) String() string

type SessionConfiguration 

type SessionConfiguration struct {

	// Milliseconds to wait for spans before sending batch
	BatchTimeout int32 `protobuf:"varint,1,opt,name=batchTimeout,proto3" json:"batchTimeout,omitempty"`
	// contains filtered or unexported fields
}

SessionConfiguration is a set of configuration values that must be used by the agent while communicating with the Orchestrator in the current session.

func (*SessionConfiguration) Descriptor deprecated 

func (*SessionConfiguration) Descriptor() ([]byte, []int)

Deprecated: Use SessionConfiguration.ProtoReflect.Descriptor instead.

func (*SessionConfiguration) GetBatchTimeout 

func (x *SessionConfiguration) GetBatchTimeout() int32

func (*SessionConfiguration) ProtoMessage 

func (*SessionConfiguration) ProtoMessage()

func (*SessionConfiguration) ProtoReflect 

func (x *SessionConfiguration) ProtoReflect() protoreflect.Message

func (*SessionConfiguration) Reset 

func (x *SessionConfiguration) Reset()

func (*SessionConfiguration) String 

func (x *SessionConfiguration) String() string

type ShutdownRequest 

type ShutdownRequest struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

ShutdownRequest is a request sent by the server to an agent so it should shut down

func (*ShutdownRequest) Descriptor deprecated 

func (*ShutdownRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) GetReason 

func (x *ShutdownRequest) GetReason() string

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

func (x *ShutdownRequest) ProtoReflect() protoreflect.Message

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type SignalfxConfig 

type SignalfxConfig struct {
	Realm string `protobuf:"bytes,1,opt,name=realm,proto3" json:"realm,omitempty"`
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*SignalfxConfig) Descriptor deprecated 

func (*SignalfxConfig) Descriptor() ([]byte, []int)

Deprecated: Use SignalfxConfig.ProtoReflect.Descriptor instead.

func (*SignalfxConfig) GetRealm 

func (x *SignalfxConfig) GetRealm() string

func (*SignalfxConfig) GetToken 

func (x *SignalfxConfig) GetToken() string

func (*SignalfxConfig) ProtoMessage 

func (*SignalfxConfig) ProtoMessage()

func (*SignalfxConfig) ProtoReflect 

func (x *SignalfxConfig) ProtoReflect() protoreflect.Message

func (*SignalfxConfig) Reset 

func (x *SignalfxConfig) Reset()

func (*SignalfxConfig) String 

func (x *SignalfxConfig) String() string

type Span 

type Span struct {
	Id         string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ParentId   string          `protobuf:"bytes,2,opt,name=parentId,proto3" json:"parentId,omitempty"`
	Name       string          `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Kind       string          `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	StartTime  int64           `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime    int64           `protobuf:"varint,6,opt,name=endTime,proto3" json:"endTime,omitempty"`
	Attributes []*KeyValuePair `protobuf:"bytes,7,rep,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*Span) Descriptor deprecated 

func (*Span) Descriptor() ([]byte, []int)

Deprecated: Use Span.ProtoReflect.Descriptor instead.

func (*Span) GetAttributes 

func (x *Span) GetAttributes() []*KeyValuePair

func (*Span) GetEndTime 

func (x *Span) GetEndTime() int64

func (*Span) GetId 

func (x *Span) GetId() string

func (*Span) GetKind 

func (x *Span) GetKind() string

func (*Span) GetName 

func (x *Span) GetName() string

func (*Span) GetParentId 

func (x *Span) GetParentId() string

func (*Span) GetStartTime 

func (x *Span) GetStartTime() int64

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) ProtoReflect 

func (x *Span) ProtoReflect() protoreflect.Message

func (*Span) Reset 

func (x *Span) Reset()

func (*Span) String 

func (x *Span) String() string

type SumoLogicConfig added in v0.15.1 

type SumoLogicConfig struct {
	URL       string `protobuf:"bytes,1,opt,name=URL,proto3" json:"URL,omitempty"`
	AccessID  string `protobuf:"bytes,2,opt,name=accessID,proto3" json:"accessID,omitempty"`
	AccessKey string `protobuf:"bytes,3,opt,name=accessKey,proto3" json:"accessKey,omitempty"`
	// contains filtered or unexported fields
}

func (*SumoLogicConfig) Descriptor deprecated added in v0.15.1 

func (*SumoLogicConfig) Descriptor() ([]byte, []int)

Deprecated: Use SumoLogicConfig.ProtoReflect.Descriptor instead.

func (*SumoLogicConfig) GetAccessID added in v0.15.1 

func (x *SumoLogicConfig) GetAccessID() string

func (*SumoLogicConfig) GetAccessKey added in v0.15.1 

func (x *SumoLogicConfig) GetAccessKey() string

func (*SumoLogicConfig) GetURL added in v0.15.1 

func (x *SumoLogicConfig) GetURL() string

func (*SumoLogicConfig) ProtoMessage added in v0.15.1 

func (*SumoLogicConfig) ProtoMessage()

func (*SumoLogicConfig) ProtoReflect added in v0.15.1 

func (x *SumoLogicConfig) ProtoReflect() protoreflect.Message

func (*SumoLogicConfig) Reset added in v0.15.1 

func (x *SumoLogicConfig) Reset()

func (*SumoLogicConfig) String added in v0.15.1 

func (x *SumoLogicConfig) String() string

type TLS 

type TLS struct {
	Insecure           bool        `protobuf:"varint,1,opt,name=insecure,proto3" json:"insecure,omitempty"`
	InsecureSkipVerify bool        `protobuf:"varint,2,opt,name=insecureSkipVerify,proto3" json:"insecureSkipVerify,omitempty"`
	ServerName         string      `protobuf:"bytes,3,opt,name=serverName,proto3" json:"serverName,omitempty"`
	Settings           *TLSSetting `protobuf:"bytes,4,opt,name=settings,proto3" json:"settings,omitempty"`
	// contains filtered or unexported fields
}

func (*TLS) Descriptor deprecated 

func (*TLS) Descriptor() ([]byte, []int)

Deprecated: Use TLS.ProtoReflect.Descriptor instead.

func (*TLS) GetInsecure 

func (x *TLS) GetInsecure() bool

func (*TLS) GetInsecureSkipVerify 

func (x *TLS) GetInsecureSkipVerify() bool

func (*TLS) GetServerName 

func (x *TLS) GetServerName() string

func (*TLS) GetSettings 

func (x *TLS) GetSettings() *TLSSetting

func (*TLS) ProtoMessage 

func (*TLS) ProtoMessage()

func (*TLS) ProtoReflect 

func (x *TLS) ProtoReflect() protoreflect.Message

func (*TLS) Reset 

func (x *TLS) Reset()

func (*TLS) String 

func (x *TLS) String() string

type TLSSetting 

type TLSSetting struct {
	CAFile     string `protobuf:"bytes,1,opt,name=cAFile,proto3" json:"cAFile,omitempty"`
	CertFile   string `protobuf:"bytes,2,opt,name=certFile,proto3" json:"certFile,omitempty"`
	KeyFile    string `protobuf:"bytes,3,opt,name=keyFile,proto3" json:"keyFile,omitempty"`
	MinVersion string `protobuf:"bytes,4,opt,name=minVersion,proto3" json:"minVersion,omitempty"`
	MaxVersion string `protobuf:"bytes,5,opt,name=maxVersion,proto3" json:"maxVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*TLSSetting) Descriptor deprecated 

func (*TLSSetting) Descriptor() ([]byte, []int)

Deprecated: Use TLSSetting.ProtoReflect.Descriptor instead.

func (*TLSSetting) GetCAFile 

func (x *TLSSetting) GetCAFile() string

func (*TLSSetting) GetCertFile 

func (x *TLSSetting) GetCertFile() string

func (*TLSSetting) GetKeyFile 

func (x *TLSSetting) GetKeyFile() string

func (*TLSSetting) GetMaxVersion 

func (x *TLSSetting) GetMaxVersion() string

func (*TLSSetting) GetMinVersion 

func (x *TLSSetting) GetMinVersion() string

func (*TLSSetting) ProtoMessage 

func (*TLSSetting) ProtoMessage()

func (*TLSSetting) ProtoReflect 

func (x *TLSSetting) ProtoReflect() protoreflect.Message

func (*TLSSetting) Reset 

func (x *TLSSetting) Reset()

func (*TLSSetting) String 

func (x *TLSSetting) String() string

type TempoConfig 

type TempoConfig struct {
	Type string              `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Http *HttpClientSettings `protobuf:"bytes,2,opt,name=http,proto3" json:"http,omitempty"`
	Grpc *GrpcClientSettings `protobuf:"bytes,3,opt,name=grpc,proto3" json:"grpc,omitempty"`
	// contains filtered or unexported fields
}

func (*TempoConfig) Descriptor deprecated 

func (*TempoConfig) Descriptor() ([]byte, []int)

Deprecated: Use TempoConfig.ProtoReflect.Descriptor instead.

func (*TempoConfig) GetGrpc 

func (x *TempoConfig) GetGrpc() *GrpcClientSettings

func (*TempoConfig) GetHttp 

func (x *TempoConfig) GetHttp() *HttpClientSettings

func (*TempoConfig) GetType 

func (x *TempoConfig) GetType() string

func (*TempoConfig) ProtoMessage 

func (*TempoConfig) ProtoMessage()

func (*TempoConfig) ProtoReflect 

func (x *TempoConfig) ProtoReflect() protoreflect.Message

func (*TempoConfig) Reset 

func (x *TempoConfig) Reset()

func (*TempoConfig) String 

func (x *TempoConfig) String() string

type TraceIDRequest 

type TraceIDRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceIDRequest) Descriptor deprecated 

func (*TraceIDRequest) Descriptor() ([]byte, []int)

Deprecated: Use TraceIDRequest.ProtoReflect.Descriptor instead.

func (*TraceIDRequest) GetId 

func (x *TraceIDRequest) GetId() string

func (*TraceIDRequest) ProtoMessage 

func (*TraceIDRequest) ProtoMessage()

func (*TraceIDRequest) ProtoReflect 

func (x *TraceIDRequest) ProtoReflect() protoreflect.Message

func (*TraceIDRequest) Reset 

func (x *TraceIDRequest) Reset()

func (*TraceIDRequest) String 

func (x *TraceIDRequest) String() string

type TraceIdResponse 

type TraceIdResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*TraceIdResponse) Descriptor deprecated 

func (*TraceIdResponse) Descriptor() ([]byte, []int)

Deprecated: Use TraceIdResponse.ProtoReflect.Descriptor instead.

func (*TraceIdResponse) GetId 

func (x *TraceIdResponse) GetId() string

func (*TraceIdResponse) ProtoMessage 

func (*TraceIdResponse) ProtoMessage()

func (*TraceIdResponse) ProtoReflect 

func (x *TraceIdResponse) ProtoReflect() protoreflect.Message

func (*TraceIdResponse) Reset 

func (x *TraceIdResponse) Reset()

func (*TraceIdResponse) String 

func (x *TraceIdResponse) String() string

type Trigger 

type Trigger struct {
	Type    string          `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Http    *HttpRequest    `protobuf:"bytes,2,opt,name=http,proto3" json:"http,omitempty"`
	Grpc    *GrpcRequest    `protobuf:"bytes,3,opt,name=grpc,proto3" json:"grpc,omitempty"`
	TraceID *TraceIDRequest `protobuf:"bytes,4,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Kafka   *KafkaRequest   `protobuf:"bytes,5,opt,name=kafka,proto3" json:"kafka,omitempty"`
	// contains filtered or unexported fields
}

func (*Trigger) Descriptor deprecated 

func (*Trigger) Descriptor() ([]byte, []int)

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetGrpc 

func (x *Trigger) GetGrpc() *GrpcRequest

func (*Trigger) GetHttp 

func (x *Trigger) GetHttp() *HttpRequest

func (*Trigger) GetKafka 

func (x *Trigger) GetKafka() *KafkaRequest

func (*Trigger) GetTraceID 

func (x *Trigger) GetTraceID() *TraceIDRequest

func (*Trigger) GetType 

func (x *Trigger) GetType() string

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect 

func (x *Trigger) ProtoReflect() protoreflect.Message

func (*Trigger) Reset 

func (x *Trigger) Reset()

func (*Trigger) String 

func (x *Trigger) String() string

type TriggerRequest 

type TriggerRequest struct {
	RequestID string   `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"`
	TestID    string   `protobuf:"bytes,2,opt,name=testID,proto3" json:"testID,omitempty"`
	RunID     int32    `protobuf:"varint,3,opt,name=runID,proto3" json:"runID,omitempty"`
	TraceID   string   `protobuf:"bytes,4,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Trigger   *Trigger `protobuf:"bytes,5,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerRequest) Descriptor deprecated 

func (*TriggerRequest) Descriptor() ([]byte, []int)

Deprecated: Use TriggerRequest.ProtoReflect.Descriptor instead.

func (*TriggerRequest) GetRequestID 

func (x *TriggerRequest) GetRequestID() string

func (*TriggerRequest) GetRunID 

func (x *TriggerRequest) GetRunID() int32

func (*TriggerRequest) GetTestID 

func (x *TriggerRequest) GetTestID() string

func (*TriggerRequest) GetTraceID 

func (x *TriggerRequest) GetTraceID() string

func (*TriggerRequest) GetTrigger 

func (x *TriggerRequest) GetTrigger() *Trigger

func (*TriggerRequest) ProtoMessage 

func (*TriggerRequest) ProtoMessage()

func (*TriggerRequest) ProtoReflect 

func (x *TriggerRequest) ProtoReflect() protoreflect.Message

func (*TriggerRequest) Reset 

func (x *TriggerRequest) Reset()

func (*TriggerRequest) String 

func (x *TriggerRequest) String() string

type TriggerResponse 

type TriggerResponse struct {
	RequestID           string               `protobuf:"bytes,1,opt,name=requestID,proto3" json:"requestID,omitempty"`
	AgentIdentification *AgentIdentification `protobuf:"bytes,2,opt,name=agentIdentification,proto3" json:"agentIdentification,omitempty"`
	TestID              string               `protobuf:"bytes,3,opt,name=testID,proto3" json:"testID,omitempty"`
	RunID               int32                `protobuf:"varint,4,opt,name=runID,proto3" json:"runID,omitempty"`
	TriggerResult       *TriggerResult       `protobuf:"bytes,5,opt,name=triggerResult,proto3" json:"triggerResult,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerResponse) Descriptor deprecated 

func (*TriggerResponse) Descriptor() ([]byte, []int)

Deprecated: Use TriggerResponse.ProtoReflect.Descriptor instead.

func (*TriggerResponse) GetAgentIdentification 

func (x *TriggerResponse) GetAgentIdentification() *AgentIdentification

func (*TriggerResponse) GetRequestID 

func (x *TriggerResponse) GetRequestID() string

func (*TriggerResponse) GetRunID 

func (x *TriggerResponse) GetRunID() int32

func (*TriggerResponse) GetTestID 

func (x *TriggerResponse) GetTestID() string

func (*TriggerResponse) GetTriggerResult 

func (x *TriggerResponse) GetTriggerResult() *TriggerResult

func (*TriggerResponse) ProtoMessage 

func (*TriggerResponse) ProtoMessage()

func (*TriggerResponse) ProtoReflect 

func (x *TriggerResponse) ProtoReflect() protoreflect.Message

func (*TriggerResponse) Reset 

func (x *TriggerResponse) Reset()

func (*TriggerResponse) String 

func (x *TriggerResponse) String() string

type TriggerResult 

type TriggerResult struct {
	Type    string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Http    *HttpResponse    `protobuf:"bytes,2,opt,name=http,proto3" json:"http,omitempty"`
	Grpc    *GrpcResponse    `protobuf:"bytes,3,opt,name=grpc,proto3" json:"grpc,omitempty"`
	TraceID *TraceIdResponse `protobuf:"bytes,4,opt,name=traceID,proto3" json:"traceID,omitempty"`
	Kafka   *KafkaResponse   `protobuf:"bytes,5,opt,name=kafka,proto3" json:"kafka,omitempty"`
	Error   *Error           `protobuf:"bytes,6,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerResult) Descriptor deprecated 

func (*TriggerResult) Descriptor() ([]byte, []int)

Deprecated: Use TriggerResult.ProtoReflect.Descriptor instead.

func (*TriggerResult) GetError added in v0.14.6 

func (x *TriggerResult) GetError() *Error

func (*TriggerResult) GetGrpc 

func (x *TriggerResult) GetGrpc() *GrpcResponse

func (*TriggerResult) GetHttp 

func (x *TriggerResult) GetHttp() *HttpResponse

func (*TriggerResult) GetKafka 

func (x *TriggerResult) GetKafka() *KafkaResponse

func (*TriggerResult) GetTraceID 

func (x *TriggerResult) GetTraceID() *TraceIdResponse

func (*TriggerResult) GetType 

func (x *TriggerResult) GetType() string

func (*TriggerResult) ProtoMessage 

func (*TriggerResult) ProtoMessage()

func (*TriggerResult) ProtoReflect 

func (x *TriggerResult) ProtoReflect() protoreflect.Message

func (*TriggerResult) Reset 

func (x *TriggerResult) Reset()

func (*TriggerResult) String 

func (x *TriggerResult) String() string

type UnimplementedOrchestratorServer 

type UnimplementedOrchestratorServer struct {
}

UnimplementedOrchestratorServer must be embedded to have forward compatible implementations.

func (UnimplementedOrchestratorServer) Connect 

func (UnimplementedOrchestratorServer) Connect(context.Context, *ConnectRequest) (*AgentConfiguration, error)

func (UnimplementedOrchestratorServer) Ping 

func (UnimplementedOrchestratorServer) Ping(context.Context, *AgentIdentification) (*Empty, error)

func (UnimplementedOrchestratorServer) RegisterDataStoreConnectionTestAgent 

func (UnimplementedOrchestratorServer) RegisterDataStoreConnectionTestAgent(*AgentIdentification, Orchestrator_RegisterDataStoreConnectionTestAgentServer) error

func (UnimplementedOrchestratorServer) RegisterPollerAgent 

func (UnimplementedOrchestratorServer) RegisterPollerAgent(*AgentIdentification, Orchestrator_RegisterPollerAgentServer) error

func (UnimplementedOrchestratorServer) RegisterShutdownListener 

func (UnimplementedOrchestratorServer) RegisterShutdownListener(*AgentIdentification, Orchestrator_RegisterShutdownListenerServer) error

func (UnimplementedOrchestratorServer) RegisterTriggerAgent 

func (UnimplementedOrchestratorServer) RegisterTriggerAgent(*AgentIdentification, Orchestrator_RegisterTriggerAgentServer) error

func (UnimplementedOrchestratorServer) SendDataStoreConnectionTestResult 

func (UnimplementedOrchestratorServer) SendDataStoreConnectionTestResult(context.Context, *DataStoreConnectionTestResponse) (*Empty, error)

func (UnimplementedOrchestratorServer) SendPolledSpans 

func (UnimplementedOrchestratorServer) SendPolledSpans(context.Context, *PollingResponse) (*Empty, error)

func (UnimplementedOrchestratorServer) SendTriggerResult 

func (UnimplementedOrchestratorServer) SendTriggerResult(context.Context, *TriggerResponse) (*Empty, error)

type UnsafeOrchestratorServer 

type UnsafeOrchestratorServer interface {
	// contains filtered or unexported methods
}

UnsafeOrchestratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OrchestratorServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.