metadatapb

package
v0.0.0-...-8540621 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterCronScriptStoreServiceServer 

func RegisterCronScriptStoreServiceServer(s *grpc.Server, srv CronScriptStoreServiceServer)

func RegisterMetadataConfigServiceServer 

func RegisterMetadataConfigServiceServer(s *grpc.Server, srv MetadataConfigServiceServer)

func RegisterMetadataServiceServer 

func RegisterMetadataServiceServer(s *grpc.Server, srv MetadataServiceServer)

func RegisterMetadataTracepointServiceServer 

func RegisterMetadataTracepointServiceServer(s *grpc.Server, srv MetadataTracepointServiceServer)

Types

type AddOrUpdateScriptRequest 

type AddOrUpdateScriptRequest struct {
	Script *cvmsgspb.CronScript `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
}

func (*AddOrUpdateScriptRequest) Descriptor 

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

func (*AddOrUpdateScriptRequest) Equal 

func (this *AddOrUpdateScriptRequest) Equal(that interface{}) bool

func (*AddOrUpdateScriptRequest) GetScript 

func (m *AddOrUpdateScriptRequest) GetScript() *cvmsgspb.CronScript

func (*AddOrUpdateScriptRequest) GoString 

func (this *AddOrUpdateScriptRequest) GoString() string

func (*AddOrUpdateScriptRequest) Marshal 

func (m *AddOrUpdateScriptRequest) Marshal() (dAtA []byte, err error)

func (*AddOrUpdateScriptRequest) MarshalTo 

func (m *AddOrUpdateScriptRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddOrUpdateScriptRequest) MarshalToSizedBuffer 

func (m *AddOrUpdateScriptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddOrUpdateScriptRequest) ProtoMessage 

func (*AddOrUpdateScriptRequest) ProtoMessage()

func (*AddOrUpdateScriptRequest) Reset 

func (m *AddOrUpdateScriptRequest) Reset()

func (*AddOrUpdateScriptRequest) Size 

func (m *AddOrUpdateScriptRequest) Size() (n int)

func (*AddOrUpdateScriptRequest) String 

func (this *AddOrUpdateScriptRequest) String() string

func (*AddOrUpdateScriptRequest) Unmarshal 

func (m *AddOrUpdateScriptRequest) Unmarshal(dAtA []byte) error

func (*AddOrUpdateScriptRequest) XXX_DiscardUnknown 

func (m *AddOrUpdateScriptRequest) XXX_DiscardUnknown()

func (*AddOrUpdateScriptRequest) XXX_Marshal 

func (m *AddOrUpdateScriptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddOrUpdateScriptRequest) XXX_Merge 

func (m *AddOrUpdateScriptRequest) XXX_Merge(src proto.Message)

func (*AddOrUpdateScriptRequest) XXX_Size 

func (m *AddOrUpdateScriptRequest) XXX_Size() int

func (*AddOrUpdateScriptRequest) XXX_Unmarshal 

func (m *AddOrUpdateScriptRequest) XXX_Unmarshal(b []byte) error

type AddOrUpdateScriptResponse 

type AddOrUpdateScriptResponse struct {
}

func (*AddOrUpdateScriptResponse) Descriptor 

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

func (*AddOrUpdateScriptResponse) Equal 

func (this *AddOrUpdateScriptResponse) Equal(that interface{}) bool

func (*AddOrUpdateScriptResponse) GoString 

func (this *AddOrUpdateScriptResponse) GoString() string

func (*AddOrUpdateScriptResponse) Marshal 

func (m *AddOrUpdateScriptResponse) Marshal() (dAtA []byte, err error)

func (*AddOrUpdateScriptResponse) MarshalTo 

func (m *AddOrUpdateScriptResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddOrUpdateScriptResponse) MarshalToSizedBuffer 

func (m *AddOrUpdateScriptResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddOrUpdateScriptResponse) ProtoMessage 

func (*AddOrUpdateScriptResponse) ProtoMessage()

func (*AddOrUpdateScriptResponse) Reset 

func (m *AddOrUpdateScriptResponse) Reset()

func (*AddOrUpdateScriptResponse) Size 

func (m *AddOrUpdateScriptResponse) Size() (n int)

func (*AddOrUpdateScriptResponse) String 

func (this *AddOrUpdateScriptResponse) String() string

func (*AddOrUpdateScriptResponse) Unmarshal 

func (m *AddOrUpdateScriptResponse) Unmarshal(dAtA []byte) error

func (*AddOrUpdateScriptResponse) XXX_DiscardUnknown 

func (m *AddOrUpdateScriptResponse) XXX_DiscardUnknown()

func (*AddOrUpdateScriptResponse) XXX_Marshal 

func (m *AddOrUpdateScriptResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddOrUpdateScriptResponse) XXX_Merge 

func (m *AddOrUpdateScriptResponse) XXX_Merge(src proto.Message)

func (*AddOrUpdateScriptResponse) XXX_Size 

func (m *AddOrUpdateScriptResponse) XXX_Size() int

func (*AddOrUpdateScriptResponse) XXX_Unmarshal 

func (m *AddOrUpdateScriptResponse) XXX_Unmarshal(b []byte) error

type AgentInfoRequest 

type AgentInfoRequest struct {
}

func (*AgentInfoRequest) Descriptor 

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

func (*AgentInfoRequest) Equal 

func (this *AgentInfoRequest) Equal(that interface{}) bool

func (*AgentInfoRequest) GoString 

func (this *AgentInfoRequest) GoString() string

func (*AgentInfoRequest) Marshal 

func (m *AgentInfoRequest) Marshal() (dAtA []byte, err error)

func (*AgentInfoRequest) MarshalTo 

func (m *AgentInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*AgentInfoRequest) MarshalToSizedBuffer 

func (m *AgentInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentInfoRequest) ProtoMessage 

func (*AgentInfoRequest) ProtoMessage()

func (*AgentInfoRequest) Reset 

func (m *AgentInfoRequest) Reset()

func (*AgentInfoRequest) Size 

func (m *AgentInfoRequest) Size() (n int)

func (*AgentInfoRequest) String 

func (this *AgentInfoRequest) String() string

func (*AgentInfoRequest) Unmarshal 

func (m *AgentInfoRequest) Unmarshal(dAtA []byte) error

func (*AgentInfoRequest) XXX_DiscardUnknown 

func (m *AgentInfoRequest) XXX_DiscardUnknown()

func (*AgentInfoRequest) XXX_Marshal 

func (m *AgentInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentInfoRequest) XXX_Merge 

func (m *AgentInfoRequest) XXX_Merge(src proto.Message)

func (*AgentInfoRequest) XXX_Size 

func (m *AgentInfoRequest) XXX_Size() int

func (*AgentInfoRequest) XXX_Unmarshal 

func (m *AgentInfoRequest) XXX_Unmarshal(b []byte) error

type AgentInfoResponse 

type AgentInfoResponse struct {
	Info []*AgentMetadata `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"`
}

func (*AgentInfoResponse) Descriptor 

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

func (*AgentInfoResponse) Equal 

func (this *AgentInfoResponse) Equal(that interface{}) bool

func (*AgentInfoResponse) GetInfo 

func (m *AgentInfoResponse) GetInfo() []*AgentMetadata

func (*AgentInfoResponse) GoString 

func (this *AgentInfoResponse) GoString() string

func (*AgentInfoResponse) Marshal 

func (m *AgentInfoResponse) Marshal() (dAtA []byte, err error)

func (*AgentInfoResponse) MarshalTo 

func (m *AgentInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*AgentInfoResponse) MarshalToSizedBuffer 

func (m *AgentInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentInfoResponse) ProtoMessage 

func (*AgentInfoResponse) ProtoMessage()

func (*AgentInfoResponse) Reset 

func (m *AgentInfoResponse) Reset()

func (*AgentInfoResponse) Size 

func (m *AgentInfoResponse) Size() (n int)

func (*AgentInfoResponse) String 

func (this *AgentInfoResponse) String() string

func (*AgentInfoResponse) Unmarshal 

func (m *AgentInfoResponse) Unmarshal(dAtA []byte) error

func (*AgentInfoResponse) XXX_DiscardUnknown 

func (m *AgentInfoResponse) XXX_DiscardUnknown()

func (*AgentInfoResponse) XXX_Marshal 

func (m *AgentInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentInfoResponse) XXX_Merge 

func (m *AgentInfoResponse) XXX_Merge(src proto.Message)

func (*AgentInfoResponse) XXX_Size 

func (m *AgentInfoResponse) XXX_Size() int

func (*AgentInfoResponse) XXX_Unmarshal 

func (m *AgentInfoResponse) XXX_Unmarshal(b []byte) error

type AgentMetadata 

type AgentMetadata struct {
	Agent      *agentpb.Agent            `protobuf:"bytes,1,opt,name=agent,proto3" json:"agent,omitempty"`
	Status     *agentpb.AgentStatus      `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	CarnotInfo *distributedpb.CarnotInfo `protobuf:"bytes,3,opt,name=carnot_info,json=carnotInfo,proto3" json:"carnot_info,omitempty"`
}

func (*AgentMetadata) Descriptor 

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

func (*AgentMetadata) Equal 

func (this *AgentMetadata) Equal(that interface{}) bool

func (*AgentMetadata) GetAgent 

func (m *AgentMetadata) GetAgent() *agentpb.Agent

func (*AgentMetadata) GetCarnotInfo 

func (m *AgentMetadata) GetCarnotInfo() *distributedpb.CarnotInfo

func (*AgentMetadata) GetStatus 

func (m *AgentMetadata) GetStatus() *agentpb.AgentStatus

func (*AgentMetadata) GoString 

func (this *AgentMetadata) GoString() string

func (*AgentMetadata) Marshal 

func (m *AgentMetadata) Marshal() (dAtA []byte, err error)

func (*AgentMetadata) MarshalTo 

func (m *AgentMetadata) MarshalTo(dAtA []byte) (int, error)

func (*AgentMetadata) MarshalToSizedBuffer 

func (m *AgentMetadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentMetadata) ProtoMessage 

func (*AgentMetadata) ProtoMessage()

func (*AgentMetadata) Reset 

func (m *AgentMetadata) Reset()

func (*AgentMetadata) Size 

func (m *AgentMetadata) Size() (n int)

func (*AgentMetadata) String 

func (this *AgentMetadata) String() string

func (*AgentMetadata) Unmarshal 

func (m *AgentMetadata) Unmarshal(dAtA []byte) error

func (*AgentMetadata) XXX_DiscardUnknown 

func (m *AgentMetadata) XXX_DiscardUnknown()

func (*AgentMetadata) XXX_Marshal 

func (m *AgentMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentMetadata) XXX_Merge 

func (m *AgentMetadata) XXX_Merge(src proto.Message)

func (*AgentMetadata) XXX_Size 

func (m *AgentMetadata) XXX_Size() int

func (*AgentMetadata) XXX_Unmarshal 

func (m *AgentMetadata) XXX_Unmarshal(b []byte) error

type AgentUpdate 

type AgentUpdate struct {
	AgentID *uuidpb.UUID `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// Types that are valid to be assigned to Update:
	//	*AgentUpdate_Deleted
	//	*AgentUpdate_Agent
	//	*AgentUpdate_DataInfo
	Update isAgentUpdate_Update `protobuf_oneof:"update"`
}

func (*AgentUpdate) Descriptor 

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

func (*AgentUpdate) Equal 

func (this *AgentUpdate) Equal(that interface{}) bool

func (*AgentUpdate) GetAgent 

func (m *AgentUpdate) GetAgent() *agentpb.Agent

func (*AgentUpdate) GetAgentID 

func (m *AgentUpdate) GetAgentID() *uuidpb.UUID

func (*AgentUpdate) GetDataInfo 

func (m *AgentUpdate) GetDataInfo() *messagespb.AgentDataInfo

func (*AgentUpdate) GetDeleted 

func (m *AgentUpdate) GetDeleted() bool

func (*AgentUpdate) GetUpdate 

func (m *AgentUpdate) GetUpdate() isAgentUpdate_Update

func (*AgentUpdate) GoString 

func (this *AgentUpdate) GoString() string

func (*AgentUpdate) Marshal 

func (m *AgentUpdate) Marshal() (dAtA []byte, err error)

func (*AgentUpdate) MarshalTo 

func (m *AgentUpdate) MarshalTo(dAtA []byte) (int, error)

func (*AgentUpdate) MarshalToSizedBuffer 

func (m *AgentUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentUpdate) ProtoMessage 

func (*AgentUpdate) ProtoMessage()

func (*AgentUpdate) Reset 

func (m *AgentUpdate) Reset()

func (*AgentUpdate) Size 

func (m *AgentUpdate) Size() (n int)

func (*AgentUpdate) String 

func (this *AgentUpdate) String() string

func (*AgentUpdate) Unmarshal 

func (m *AgentUpdate) Unmarshal(dAtA []byte) error

func (*AgentUpdate) XXX_DiscardUnknown 

func (m *AgentUpdate) XXX_DiscardUnknown()

func (*AgentUpdate) XXX_Marshal 

func (m *AgentUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentUpdate) XXX_Merge 

func (m *AgentUpdate) XXX_Merge(src proto.Message)

func (*AgentUpdate) XXX_OneofWrappers 

func (*AgentUpdate) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AgentUpdate) XXX_Size 

func (m *AgentUpdate) XXX_Size() int

func (*AgentUpdate) XXX_Unmarshal 

func (m *AgentUpdate) XXX_Unmarshal(b []byte) error

type AgentUpdate_Agent 

type AgentUpdate_Agent struct {
	Agent *agentpb.Agent `protobuf:"bytes,3,opt,name=agent,proto3,oneof" json:"agent,omitempty"`
}

func (*AgentUpdate_Agent) Equal 

func (this *AgentUpdate_Agent) Equal(that interface{}) bool

func (*AgentUpdate_Agent) GoString 

func (this *AgentUpdate_Agent) GoString() string

func (*AgentUpdate_Agent) MarshalTo 

func (m *AgentUpdate_Agent) MarshalTo(dAtA []byte) (int, error)

func (*AgentUpdate_Agent) MarshalToSizedBuffer 

func (m *AgentUpdate_Agent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentUpdate_Agent) Size 

func (m *AgentUpdate_Agent) Size() (n int)

func (*AgentUpdate_Agent) String 

func (this *AgentUpdate_Agent) String() string

type AgentUpdate_DataInfo 

type AgentUpdate_DataInfo struct {
	DataInfo *messagespb.AgentDataInfo `protobuf:"bytes,4,opt,name=data_info,json=dataInfo,proto3,oneof" json:"data_info,omitempty"`
}

func (*AgentUpdate_DataInfo) Equal 

func (this *AgentUpdate_DataInfo) Equal(that interface{}) bool

func (*AgentUpdate_DataInfo) GoString 

func (this *AgentUpdate_DataInfo) GoString() string

func (*AgentUpdate_DataInfo) MarshalTo 

func (m *AgentUpdate_DataInfo) MarshalTo(dAtA []byte) (int, error)

func (*AgentUpdate_DataInfo) MarshalToSizedBuffer 

func (m *AgentUpdate_DataInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentUpdate_DataInfo) Size 

func (m *AgentUpdate_DataInfo) Size() (n int)

func (*AgentUpdate_DataInfo) String 

func (this *AgentUpdate_DataInfo) String() string

type AgentUpdate_Deleted 

type AgentUpdate_Deleted struct {
	Deleted bool `protobuf:"varint,2,opt,name=deleted,proto3,oneof" json:"deleted,omitempty"`
}

func (*AgentUpdate_Deleted) Equal 

func (this *AgentUpdate_Deleted) Equal(that interface{}) bool

func (*AgentUpdate_Deleted) GoString 

func (this *AgentUpdate_Deleted) GoString() string

func (*AgentUpdate_Deleted) MarshalTo 

func (m *AgentUpdate_Deleted) MarshalTo(dAtA []byte) (int, error)

func (*AgentUpdate_Deleted) MarshalToSizedBuffer 

func (m *AgentUpdate_Deleted) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentUpdate_Deleted) Size 

func (m *AgentUpdate_Deleted) Size() (n int)

func (*AgentUpdate_Deleted) String 

func (this *AgentUpdate_Deleted) String() string

type AgentUpdatesRequest 

type AgentUpdatesRequest struct {
	MaxUpdateInterval     *types.Duration `protobuf:"bytes,1,opt,name=max_update_interval,json=maxUpdateInterval,proto3" json:"max_update_interval,omitempty"`
	MaxUpdatesPerResponse int32           `` /* 129-byte string literal not displayed */
}

func (*AgentUpdatesRequest) Descriptor 

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

func (*AgentUpdatesRequest) Equal 

func (this *AgentUpdatesRequest) Equal(that interface{}) bool

func (*AgentUpdatesRequest) GetMaxUpdateInterval 

func (m *AgentUpdatesRequest) GetMaxUpdateInterval() *types.Duration

func (*AgentUpdatesRequest) GetMaxUpdatesPerResponse 

func (m *AgentUpdatesRequest) GetMaxUpdatesPerResponse() int32

func (*AgentUpdatesRequest) GoString 

func (this *AgentUpdatesRequest) GoString() string

func (*AgentUpdatesRequest) Marshal 

func (m *AgentUpdatesRequest) Marshal() (dAtA []byte, err error)

func (*AgentUpdatesRequest) MarshalTo 

func (m *AgentUpdatesRequest) MarshalTo(dAtA []byte) (int, error)

func (*AgentUpdatesRequest) MarshalToSizedBuffer 

func (m *AgentUpdatesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentUpdatesRequest) ProtoMessage 

func (*AgentUpdatesRequest) ProtoMessage()

func (*AgentUpdatesRequest) Reset 

func (m *AgentUpdatesRequest) Reset()

func (*AgentUpdatesRequest) Size 

func (m *AgentUpdatesRequest) Size() (n int)

func (*AgentUpdatesRequest) String 

func (this *AgentUpdatesRequest) String() string

func (*AgentUpdatesRequest) Unmarshal 

func (m *AgentUpdatesRequest) Unmarshal(dAtA []byte) error

func (*AgentUpdatesRequest) XXX_DiscardUnknown 

func (m *AgentUpdatesRequest) XXX_DiscardUnknown()

func (*AgentUpdatesRequest) XXX_Marshal 

func (m *AgentUpdatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentUpdatesRequest) XXX_Merge 

func (m *AgentUpdatesRequest) XXX_Merge(src proto.Message)

func (*AgentUpdatesRequest) XXX_Size 

func (m *AgentUpdatesRequest) XXX_Size() int

func (*AgentUpdatesRequest) XXX_Unmarshal 

func (m *AgentUpdatesRequest) XXX_Unmarshal(b []byte) error

type AgentUpdatesResponse 

type AgentUpdatesResponse struct {
	AgentUpdates        []*AgentUpdate              `protobuf:"bytes,1,rep,name=agent_updates,json=agentUpdates,proto3" json:"agent_updates,omitempty"`
	AgentSchemas        []*distributedpb.SchemaInfo `protobuf:"bytes,2,rep,name=agent_schemas,json=agentSchemas,proto3" json:"agent_schemas,omitempty"`
	AgentSchemasUpdated bool                        `protobuf:"varint,3,opt,name=agent_schemas_updated,json=agentSchemasUpdated,proto3" json:"agent_schemas_updated,omitempty"`
	EndOfVersion        bool                        `protobuf:"varint,4,opt,name=end_of_version,json=endOfVersion,proto3" json:"end_of_version,omitempty"`
}

func (*AgentUpdatesResponse) Descriptor 

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

func (*AgentUpdatesResponse) Equal 

func (this *AgentUpdatesResponse) Equal(that interface{}) bool

func (*AgentUpdatesResponse) GetAgentSchemas 

func (m *AgentUpdatesResponse) GetAgentSchemas() []*distributedpb.SchemaInfo

func (*AgentUpdatesResponse) GetAgentSchemasUpdated 

func (m *AgentUpdatesResponse) GetAgentSchemasUpdated() bool

func (*AgentUpdatesResponse) GetAgentUpdates 

func (m *AgentUpdatesResponse) GetAgentUpdates() []*AgentUpdate

func (*AgentUpdatesResponse) GetEndOfVersion 

func (m *AgentUpdatesResponse) GetEndOfVersion() bool

func (*AgentUpdatesResponse) GoString 

func (this *AgentUpdatesResponse) GoString() string

func (*AgentUpdatesResponse) Marshal 

func (m *AgentUpdatesResponse) Marshal() (dAtA []byte, err error)

func (*AgentUpdatesResponse) MarshalTo 

func (m *AgentUpdatesResponse) MarshalTo(dAtA []byte) (int, error)

func (*AgentUpdatesResponse) MarshalToSizedBuffer 

func (m *AgentUpdatesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AgentUpdatesResponse) ProtoMessage 

func (*AgentUpdatesResponse) ProtoMessage()

func (*AgentUpdatesResponse) Reset 

func (m *AgentUpdatesResponse) Reset()

func (*AgentUpdatesResponse) Size 

func (m *AgentUpdatesResponse) Size() (n int)

func (*AgentUpdatesResponse) String 

func (this *AgentUpdatesResponse) String() string

func (*AgentUpdatesResponse) Unmarshal 

func (m *AgentUpdatesResponse) Unmarshal(dAtA []byte) error

func (*AgentUpdatesResponse) XXX_DiscardUnknown 

func (m *AgentUpdatesResponse) XXX_DiscardUnknown()

func (*AgentUpdatesResponse) XXX_Marshal 

func (m *AgentUpdatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AgentUpdatesResponse) XXX_Merge 

func (m *AgentUpdatesResponse) XXX_Merge(src proto.Message)

func (*AgentUpdatesResponse) XXX_Size 

func (m *AgentUpdatesResponse) XXX_Size() int

func (*AgentUpdatesResponse) XXX_Unmarshal 

func (m *AgentUpdatesResponse) XXX_Unmarshal(b []byte) error

type CronScriptStoreServiceClient 

type CronScriptStoreServiceClient interface {
	GetScripts(ctx context.Context, in *GetScriptsRequest, opts ...grpc.CallOption) (*GetScriptsResponse, error)
	AddOrUpdateScript(ctx context.Context, in *AddOrUpdateScriptRequest, opts ...grpc.CallOption) (*AddOrUpdateScriptResponse, error)
	DeleteScript(ctx context.Context, in *DeleteScriptRequest, opts ...grpc.CallOption) (*DeleteScriptResponse, error)
	SetScripts(ctx context.Context, in *SetScriptsRequest, opts ...grpc.CallOption) (*SetScriptsResponse, error)
	RecordExecutionResult(ctx context.Context, in *RecordExecutionResultRequest, opts ...grpc.CallOption) (*RecordExecutionResultResponse, error)
	GetAllExecutionResults(ctx context.Context, in *GetAllExecutionResultsRequest, opts ...grpc.CallOption) (*GetAllExecutionResultsResponse, error)
}

CronScriptStoreServiceClient is the client API for CronScriptStoreService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCronScriptStoreServiceClient 

func NewCronScriptStoreServiceClient(cc *grpc.ClientConn) CronScriptStoreServiceClient

type CronScriptStoreServiceServer 

type CronScriptStoreServiceServer interface {
	GetScripts(context.Context, *GetScriptsRequest) (*GetScriptsResponse, error)
	AddOrUpdateScript(context.Context, *AddOrUpdateScriptRequest) (*AddOrUpdateScriptResponse, error)
	DeleteScript(context.Context, *DeleteScriptRequest) (*DeleteScriptResponse, error)
	SetScripts(context.Context, *SetScriptsRequest) (*SetScriptsResponse, error)
	RecordExecutionResult(context.Context, *RecordExecutionResultRequest) (*RecordExecutionResultResponse, error)
	GetAllExecutionResults(context.Context, *GetAllExecutionResultsRequest) (*GetAllExecutionResultsResponse, error)
}

CronScriptStoreServiceServer is the server API for CronScriptStoreService service.

type DeleteScriptRequest 

type DeleteScriptRequest struct {
	ScriptID *uuidpb.UUID `protobuf:"bytes,1,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty"`
}

func (*DeleteScriptRequest) Descriptor 

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

func (*DeleteScriptRequest) Equal 

func (this *DeleteScriptRequest) Equal(that interface{}) bool

func (*DeleteScriptRequest) GetScriptID 

func (m *DeleteScriptRequest) GetScriptID() *uuidpb.UUID

func (*DeleteScriptRequest) GoString 

func (this *DeleteScriptRequest) GoString() string

func (*DeleteScriptRequest) Marshal 

func (m *DeleteScriptRequest) Marshal() (dAtA []byte, err error)

func (*DeleteScriptRequest) MarshalTo 

func (m *DeleteScriptRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteScriptRequest) MarshalToSizedBuffer 

func (m *DeleteScriptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteScriptRequest) ProtoMessage 

func (*DeleteScriptRequest) ProtoMessage()

func (*DeleteScriptRequest) Reset 

func (m *DeleteScriptRequest) Reset()

func (*DeleteScriptRequest) Size 

func (m *DeleteScriptRequest) Size() (n int)

func (*DeleteScriptRequest) String 

func (this *DeleteScriptRequest) String() string

func (*DeleteScriptRequest) Unmarshal 

func (m *DeleteScriptRequest) Unmarshal(dAtA []byte) error

func (*DeleteScriptRequest) XXX_DiscardUnknown 

func (m *DeleteScriptRequest) XXX_DiscardUnknown()

func (*DeleteScriptRequest) XXX_Marshal 

func (m *DeleteScriptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteScriptRequest) XXX_Merge 

func (m *DeleteScriptRequest) XXX_Merge(src proto.Message)

func (*DeleteScriptRequest) XXX_Size 

func (m *DeleteScriptRequest) XXX_Size() int

func (*DeleteScriptRequest) XXX_Unmarshal 

func (m *DeleteScriptRequest) XXX_Unmarshal(b []byte) error

type DeleteScriptResponse 

type DeleteScriptResponse struct {
}

func (*DeleteScriptResponse) Descriptor 

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

func (*DeleteScriptResponse) Equal 

func (this *DeleteScriptResponse) Equal(that interface{}) bool

func (*DeleteScriptResponse) GoString 

func (this *DeleteScriptResponse) GoString() string

func (*DeleteScriptResponse) Marshal 

func (m *DeleteScriptResponse) Marshal() (dAtA []byte, err error)

func (*DeleteScriptResponse) MarshalTo 

func (m *DeleteScriptResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteScriptResponse) MarshalToSizedBuffer 

func (m *DeleteScriptResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteScriptResponse) ProtoMessage 

func (*DeleteScriptResponse) ProtoMessage()

func (*DeleteScriptResponse) Reset 

func (m *DeleteScriptResponse) Reset()

func (*DeleteScriptResponse) Size 

func (m *DeleteScriptResponse) Size() (n int)

func (*DeleteScriptResponse) String 

func (this *DeleteScriptResponse) String() string

func (*DeleteScriptResponse) Unmarshal 

func (m *DeleteScriptResponse) Unmarshal(dAtA []byte) error

func (*DeleteScriptResponse) XXX_DiscardUnknown 

func (m *DeleteScriptResponse) XXX_DiscardUnknown()

func (*DeleteScriptResponse) XXX_Marshal 

func (m *DeleteScriptResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteScriptResponse) XXX_Merge 

func (m *DeleteScriptResponse) XXX_Merge(src proto.Message)

func (*DeleteScriptResponse) XXX_Size 

func (m *DeleteScriptResponse) XXX_Size() int

func (*DeleteScriptResponse) XXX_Unmarshal 

func (m *DeleteScriptResponse) XXX_Unmarshal(b []byte) error

type ExecutionStats 

type ExecutionStats struct {
	ExecutionTimeNs   int64 `protobuf:"varint,1,opt,name=execution_time_ns,json=executionTimeNs,proto3" json:"execution_time_ns,omitempty"`
	CompilationTimeNs int64 `protobuf:"varint,2,opt,name=compilation_time_ns,json=compilationTimeNs,proto3" json:"compilation_time_ns,omitempty"`
	BytesProcessed    int64 `protobuf:"varint,3,opt,name=bytes_processed,json=bytesProcessed,proto3" json:"bytes_processed,omitempty"`
	RecordsProcessed  int64 `protobuf:"varint,4,opt,name=records_processed,json=recordsProcessed,proto3" json:"records_processed,omitempty"`
}

func (*ExecutionStats) Descriptor 

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

func (*ExecutionStats) Equal 

func (this *ExecutionStats) Equal(that interface{}) bool

func (*ExecutionStats) GetBytesProcessed 

func (m *ExecutionStats) GetBytesProcessed() int64

func (*ExecutionStats) GetCompilationTimeNs 

func (m *ExecutionStats) GetCompilationTimeNs() int64

func (*ExecutionStats) GetExecutionTimeNs 

func (m *ExecutionStats) GetExecutionTimeNs() int64

func (*ExecutionStats) GetRecordsProcessed 

func (m *ExecutionStats) GetRecordsProcessed() int64

func (*ExecutionStats) GoString 

func (this *ExecutionStats) GoString() string

func (*ExecutionStats) Marshal 

func (m *ExecutionStats) Marshal() (dAtA []byte, err error)

func (*ExecutionStats) MarshalTo 

func (m *ExecutionStats) MarshalTo(dAtA []byte) (int, error)

func (*ExecutionStats) MarshalToSizedBuffer 

func (m *ExecutionStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExecutionStats) ProtoMessage 

func (*ExecutionStats) ProtoMessage()

func (*ExecutionStats) Reset 

func (m *ExecutionStats) Reset()

func (*ExecutionStats) Size 

func (m *ExecutionStats) Size() (n int)

func (*ExecutionStats) String 

func (this *ExecutionStats) String() string

func (*ExecutionStats) Unmarshal 

func (m *ExecutionStats) Unmarshal(dAtA []byte) error

func (*ExecutionStats) XXX_DiscardUnknown 

func (m *ExecutionStats) XXX_DiscardUnknown()

func (*ExecutionStats) XXX_Marshal 

func (m *ExecutionStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ExecutionStats) XXX_Merge 

func (m *ExecutionStats) XXX_Merge(src proto.Message)

func (*ExecutionStats) XXX_Size 

func (m *ExecutionStats) XXX_Size() int

func (*ExecutionStats) XXX_Unmarshal 

func (m *ExecutionStats) XXX_Unmarshal(b []byte) error

type GetAllExecutionResultsRequest 

type GetAllExecutionResultsRequest struct {
}

func (*GetAllExecutionResultsRequest) Descriptor 

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

func (*GetAllExecutionResultsRequest) Equal 

func (this *GetAllExecutionResultsRequest) Equal(that interface{}) bool

func (*GetAllExecutionResultsRequest) GoString 

func (this *GetAllExecutionResultsRequest) GoString() string

func (*GetAllExecutionResultsRequest) Marshal 

func (m *GetAllExecutionResultsRequest) Marshal() (dAtA []byte, err error)

func (*GetAllExecutionResultsRequest) MarshalTo 

func (m *GetAllExecutionResultsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetAllExecutionResultsRequest) MarshalToSizedBuffer 

func (m *GetAllExecutionResultsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllExecutionResultsRequest) ProtoMessage 

func (*GetAllExecutionResultsRequest) ProtoMessage()

func (*GetAllExecutionResultsRequest) Reset 

func (m *GetAllExecutionResultsRequest) Reset()

func (*GetAllExecutionResultsRequest) Size 

func (m *GetAllExecutionResultsRequest) Size() (n int)

func (*GetAllExecutionResultsRequest) String 

func (this *GetAllExecutionResultsRequest) String() string

func (*GetAllExecutionResultsRequest) Unmarshal 

func (m *GetAllExecutionResultsRequest) Unmarshal(dAtA []byte) error

func (*GetAllExecutionResultsRequest) XXX_DiscardUnknown 

func (m *GetAllExecutionResultsRequest) XXX_DiscardUnknown()

func (*GetAllExecutionResultsRequest) XXX_Marshal 

func (m *GetAllExecutionResultsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllExecutionResultsRequest) XXX_Merge 

func (m *GetAllExecutionResultsRequest) XXX_Merge(src proto.Message)

func (*GetAllExecutionResultsRequest) XXX_Size 

func (m *GetAllExecutionResultsRequest) XXX_Size() int

func (*GetAllExecutionResultsRequest) XXX_Unmarshal 

func (m *GetAllExecutionResultsRequest) XXX_Unmarshal(b []byte) error

type GetAllExecutionResultsResponse 

type GetAllExecutionResultsResponse struct {
	Results []*GetAllExecutionResultsResponse_ExecutionResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
}

func (*GetAllExecutionResultsResponse) Descriptor 

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

func (*GetAllExecutionResultsResponse) Equal 

func (this *GetAllExecutionResultsResponse) Equal(that interface{}) bool

func (*GetAllExecutionResultsResponse) GetResults 

func (m *GetAllExecutionResultsResponse) GetResults() []*GetAllExecutionResultsResponse_ExecutionResult

func (*GetAllExecutionResultsResponse) GoString 

func (this *GetAllExecutionResultsResponse) GoString() string

func (*GetAllExecutionResultsResponse) Marshal 

func (m *GetAllExecutionResultsResponse) Marshal() (dAtA []byte, err error)

func (*GetAllExecutionResultsResponse) MarshalTo 

func (m *GetAllExecutionResultsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetAllExecutionResultsResponse) MarshalToSizedBuffer 

func (m *GetAllExecutionResultsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllExecutionResultsResponse) ProtoMessage 

func (*GetAllExecutionResultsResponse) ProtoMessage()

func (*GetAllExecutionResultsResponse) Reset 

func (m *GetAllExecutionResultsResponse) Reset()

func (*GetAllExecutionResultsResponse) Size 

func (m *GetAllExecutionResultsResponse) Size() (n int)

func (*GetAllExecutionResultsResponse) String 

func (this *GetAllExecutionResultsResponse) String() string

func (*GetAllExecutionResultsResponse) Unmarshal 

func (m *GetAllExecutionResultsResponse) Unmarshal(dAtA []byte) error

func (*GetAllExecutionResultsResponse) XXX_DiscardUnknown 

func (m *GetAllExecutionResultsResponse) XXX_DiscardUnknown()

func (*GetAllExecutionResultsResponse) XXX_Marshal 

func (m *GetAllExecutionResultsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllExecutionResultsResponse) XXX_Merge 

func (m *GetAllExecutionResultsResponse) XXX_Merge(src proto.Message)

func (*GetAllExecutionResultsResponse) XXX_Size 

func (m *GetAllExecutionResultsResponse) XXX_Size() int

func (*GetAllExecutionResultsResponse) XXX_Unmarshal 

func (m *GetAllExecutionResultsResponse) XXX_Unmarshal(b []byte) error

type GetAllExecutionResultsResponse_ExecutionResult 

type GetAllExecutionResultsResponse_ExecutionResult struct {
	ScriptID  *uuidpb.UUID     `protobuf:"bytes,1,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty"`
	Timestamp *types.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are valid to be assigned to Result:
	//	*GetAllExecutionResultsResponse_ExecutionResult_Error
	//	*GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats
	Result isGetAllExecutionResultsResponse_ExecutionResult_Result `protobuf_oneof:"result"`
}

func (*GetAllExecutionResultsResponse_ExecutionResult) Descriptor 

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

func (*GetAllExecutionResultsResponse_ExecutionResult) Equal 

func (this *GetAllExecutionResultsResponse_ExecutionResult) Equal(that interface{}) bool

func (*GetAllExecutionResultsResponse_ExecutionResult) GetError 

func (m *GetAllExecutionResultsResponse_ExecutionResult) GetError() *statuspb.Status

func (*GetAllExecutionResultsResponse_ExecutionResult) GetExecutionStats 

func (m *GetAllExecutionResultsResponse_ExecutionResult) GetExecutionStats() *ExecutionStats

func (*GetAllExecutionResultsResponse_ExecutionResult) GetResult 

func (m *GetAllExecutionResultsResponse_ExecutionResult) GetResult() isGetAllExecutionResultsResponse_ExecutionResult_Result

func (*GetAllExecutionResultsResponse_ExecutionResult) GetScriptID 

func (m *GetAllExecutionResultsResponse_ExecutionResult) GetScriptID() *uuidpb.UUID

func (*GetAllExecutionResultsResponse_ExecutionResult) GetTimestamp 

func (m *GetAllExecutionResultsResponse_ExecutionResult) GetTimestamp() *types.Timestamp

func (*GetAllExecutionResultsResponse_ExecutionResult) GoString 

func (this *GetAllExecutionResultsResponse_ExecutionResult) GoString() string

func (*GetAllExecutionResultsResponse_ExecutionResult) Marshal 

func (m *GetAllExecutionResultsResponse_ExecutionResult) Marshal() (dAtA []byte, err error)

func (*GetAllExecutionResultsResponse_ExecutionResult) MarshalTo 

func (m *GetAllExecutionResultsResponse_ExecutionResult) MarshalTo(dAtA []byte) (int, error)

func (*GetAllExecutionResultsResponse_ExecutionResult) MarshalToSizedBuffer 

func (m *GetAllExecutionResultsResponse_ExecutionResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllExecutionResultsResponse_ExecutionResult) ProtoMessage 

func (*GetAllExecutionResultsResponse_ExecutionResult) ProtoMessage()

func (*GetAllExecutionResultsResponse_ExecutionResult) Reset 

func (m *GetAllExecutionResultsResponse_ExecutionResult) Reset()

func (*GetAllExecutionResultsResponse_ExecutionResult) Size 

func (m *GetAllExecutionResultsResponse_ExecutionResult) Size() (n int)

func (*GetAllExecutionResultsResponse_ExecutionResult) String 

func (this *GetAllExecutionResultsResponse_ExecutionResult) String() string

func (*GetAllExecutionResultsResponse_ExecutionResult) Unmarshal 

func (m *GetAllExecutionResultsResponse_ExecutionResult) Unmarshal(dAtA []byte) error

func (*GetAllExecutionResultsResponse_ExecutionResult) XXX_DiscardUnknown 

func (m *GetAllExecutionResultsResponse_ExecutionResult) XXX_DiscardUnknown()

func (*GetAllExecutionResultsResponse_ExecutionResult) XXX_Marshal 

func (m *GetAllExecutionResultsResponse_ExecutionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAllExecutionResultsResponse_ExecutionResult) XXX_Merge 

func (m *GetAllExecutionResultsResponse_ExecutionResult) XXX_Merge(src proto.Message)

func (*GetAllExecutionResultsResponse_ExecutionResult) XXX_OneofWrappers 

func (*GetAllExecutionResultsResponse_ExecutionResult) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GetAllExecutionResultsResponse_ExecutionResult) XXX_Size 

func (m *GetAllExecutionResultsResponse_ExecutionResult) XXX_Size() int

func (*GetAllExecutionResultsResponse_ExecutionResult) XXX_Unmarshal 

func (m *GetAllExecutionResultsResponse_ExecutionResult) XXX_Unmarshal(b []byte) error

type GetAllExecutionResultsResponse_ExecutionResult_Error 

type GetAllExecutionResultsResponse_ExecutionResult_Error struct {
	Error *statuspb.Status `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

func (*GetAllExecutionResultsResponse_ExecutionResult_Error) Equal 

func (this *GetAllExecutionResultsResponse_ExecutionResult_Error) Equal(that interface{}) bool

func (*GetAllExecutionResultsResponse_ExecutionResult_Error) GoString 

func (this *GetAllExecutionResultsResponse_ExecutionResult_Error) GoString() string

func (*GetAllExecutionResultsResponse_ExecutionResult_Error) MarshalTo 

func (m *GetAllExecutionResultsResponse_ExecutionResult_Error) MarshalTo(dAtA []byte) (int, error)

func (*GetAllExecutionResultsResponse_ExecutionResult_Error) MarshalToSizedBuffer 

func (m *GetAllExecutionResultsResponse_ExecutionResult_Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllExecutionResultsResponse_ExecutionResult_Error) Size 

func (m *GetAllExecutionResultsResponse_ExecutionResult_Error) Size() (n int)

func (*GetAllExecutionResultsResponse_ExecutionResult_Error) String 

func (this *GetAllExecutionResultsResponse_ExecutionResult_Error) String() string

type GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats 

type GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats struct {
	ExecutionStats *ExecutionStats `protobuf:"bytes,4,opt,name=execution_stats,json=executionStats,proto3,oneof" json:"execution_stats,omitempty"`
}

func (*GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) Equal 

func (this *GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) Equal(that interface{}) bool

func (*GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) GoString 

func (this *GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) GoString() string

func (*GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) MarshalTo 

func (m *GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) MarshalTo(dAtA []byte) (int, error)

func (*GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) MarshalToSizedBuffer 

func (m *GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) Size 

func (m *GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) Size() (n int)

func (*GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) String 

func (this *GetAllExecutionResultsResponse_ExecutionResult_ExecutionStats) String() string

type GetScriptsRequest 

type GetScriptsRequest struct {
}

func (*GetScriptsRequest) Descriptor 

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

func (*GetScriptsRequest) Equal 

func (this *GetScriptsRequest) Equal(that interface{}) bool

func (*GetScriptsRequest) GoString 

func (this *GetScriptsRequest) GoString() string

func (*GetScriptsRequest) Marshal 

func (m *GetScriptsRequest) Marshal() (dAtA []byte, err error)

func (*GetScriptsRequest) MarshalTo 

func (m *GetScriptsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetScriptsRequest) MarshalToSizedBuffer 

func (m *GetScriptsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetScriptsRequest) ProtoMessage 

func (*GetScriptsRequest) ProtoMessage()

func (*GetScriptsRequest) Reset 

func (m *GetScriptsRequest) Reset()

func (*GetScriptsRequest) Size 

func (m *GetScriptsRequest) Size() (n int)

func (*GetScriptsRequest) String 

func (this *GetScriptsRequest) String() string

func (*GetScriptsRequest) Unmarshal 

func (m *GetScriptsRequest) Unmarshal(dAtA []byte) error

func (*GetScriptsRequest) XXX_DiscardUnknown 

func (m *GetScriptsRequest) XXX_DiscardUnknown()

func (*GetScriptsRequest) XXX_Marshal 

func (m *GetScriptsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetScriptsRequest) XXX_Merge 

func (m *GetScriptsRequest) XXX_Merge(src proto.Message)

func (*GetScriptsRequest) XXX_Size 

func (m *GetScriptsRequest) XXX_Size() int

func (*GetScriptsRequest) XXX_Unmarshal 

func (m *GetScriptsRequest) XXX_Unmarshal(b []byte) error

type GetScriptsResponse 

type GetScriptsResponse struct {
	Scripts map[string]*cvmsgspb.CronScript `` /* 155-byte string literal not displayed */
}

func (*GetScriptsResponse) Descriptor 

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

func (*GetScriptsResponse) Equal 

func (this *GetScriptsResponse) Equal(that interface{}) bool

func (*GetScriptsResponse) GetScripts 

func (m *GetScriptsResponse) GetScripts() map[string]*cvmsgspb.CronScript

func (*GetScriptsResponse) GoString 

func (this *GetScriptsResponse) GoString() string

func (*GetScriptsResponse) Marshal 

func (m *GetScriptsResponse) Marshal() (dAtA []byte, err error)

func (*GetScriptsResponse) MarshalTo 

func (m *GetScriptsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetScriptsResponse) MarshalToSizedBuffer 

func (m *GetScriptsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetScriptsResponse) ProtoMessage 

func (*GetScriptsResponse) ProtoMessage()

func (*GetScriptsResponse) Reset 

func (m *GetScriptsResponse) Reset()

func (*GetScriptsResponse) Size 

func (m *GetScriptsResponse) Size() (n int)

func (*GetScriptsResponse) String 

func (this *GetScriptsResponse) String() string

func (*GetScriptsResponse) Unmarshal 

func (m *GetScriptsResponse) Unmarshal(dAtA []byte) error

func (*GetScriptsResponse) XXX_DiscardUnknown 

func (m *GetScriptsResponse) XXX_DiscardUnknown()

func (*GetScriptsResponse) XXX_Marshal 

func (m *GetScriptsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetScriptsResponse) XXX_Merge 

func (m *GetScriptsResponse) XXX_Merge(src proto.Message)

func (*GetScriptsResponse) XXX_Size 

func (m *GetScriptsResponse) XXX_Size() int

func (*GetScriptsResponse) XXX_Unmarshal 

func (m *GetScriptsResponse) XXX_Unmarshal(b []byte) error

type GetTracepointInfoRequest 

type GetTracepointInfoRequest struct {
	IDs []*uuidpb.UUID `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
}

func (*GetTracepointInfoRequest) Descriptor 

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

func (*GetTracepointInfoRequest) Equal 

func (this *GetTracepointInfoRequest) Equal(that interface{}) bool

func (*GetTracepointInfoRequest) GetIDs 

func (m *GetTracepointInfoRequest) GetIDs() []*uuidpb.UUID

func (*GetTracepointInfoRequest) GoString 

func (this *GetTracepointInfoRequest) GoString() string

func (*GetTracepointInfoRequest) Marshal 

func (m *GetTracepointInfoRequest) Marshal() (dAtA []byte, err error)

func (*GetTracepointInfoRequest) MarshalTo 

func (m *GetTracepointInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetTracepointInfoRequest) MarshalToSizedBuffer 

func (m *GetTracepointInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTracepointInfoRequest) ProtoMessage 

func (*GetTracepointInfoRequest) ProtoMessage()

func (*GetTracepointInfoRequest) Reset 

func (m *GetTracepointInfoRequest) Reset()

func (*GetTracepointInfoRequest) Size 

func (m *GetTracepointInfoRequest) Size() (n int)

func (*GetTracepointInfoRequest) String 

func (this *GetTracepointInfoRequest) String() string

func (*GetTracepointInfoRequest) Unmarshal 

func (m *GetTracepointInfoRequest) Unmarshal(dAtA []byte) error

func (*GetTracepointInfoRequest) XXX_DiscardUnknown 

func (m *GetTracepointInfoRequest) XXX_DiscardUnknown()

func (*GetTracepointInfoRequest) XXX_Marshal 

func (m *GetTracepointInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTracepointInfoRequest) XXX_Merge 

func (m *GetTracepointInfoRequest) XXX_Merge(src proto.Message)

func (*GetTracepointInfoRequest) XXX_Size 

func (m *GetTracepointInfoRequest) XXX_Size() int

func (*GetTracepointInfoRequest) XXX_Unmarshal 

func (m *GetTracepointInfoRequest) XXX_Unmarshal(b []byte) error

type GetTracepointInfoResponse 

type GetTracepointInfoResponse struct {
	Tracepoints []*GetTracepointInfoResponse_TracepointState `protobuf:"bytes,1,rep,name=tracepoints,proto3" json:"tracepoints,omitempty"`
}

func (*GetTracepointInfoResponse) Descriptor 

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

func (*GetTracepointInfoResponse) Equal 

func (this *GetTracepointInfoResponse) Equal(that interface{}) bool

func (*GetTracepointInfoResponse) GetTracepoints 

func (m *GetTracepointInfoResponse) GetTracepoints() []*GetTracepointInfoResponse_TracepointState

func (*GetTracepointInfoResponse) GoString 

func (this *GetTracepointInfoResponse) GoString() string

func (*GetTracepointInfoResponse) Marshal 

func (m *GetTracepointInfoResponse) Marshal() (dAtA []byte, err error)

func (*GetTracepointInfoResponse) MarshalTo 

func (m *GetTracepointInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetTracepointInfoResponse) MarshalToSizedBuffer 

func (m *GetTracepointInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTracepointInfoResponse) ProtoMessage 

func (*GetTracepointInfoResponse) ProtoMessage()

func (*GetTracepointInfoResponse) Reset 

func (m *GetTracepointInfoResponse) Reset()

func (*GetTracepointInfoResponse) Size 

func (m *GetTracepointInfoResponse) Size() (n int)

func (*GetTracepointInfoResponse) String 

func (this *GetTracepointInfoResponse) String() string

func (*GetTracepointInfoResponse) Unmarshal 

func (m *GetTracepointInfoResponse) Unmarshal(dAtA []byte) error

func (*GetTracepointInfoResponse) XXX_DiscardUnknown 

func (m *GetTracepointInfoResponse) XXX_DiscardUnknown()

func (*GetTracepointInfoResponse) XXX_Marshal 

func (m *GetTracepointInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTracepointInfoResponse) XXX_Merge 

func (m *GetTracepointInfoResponse) XXX_Merge(src proto.Message)

func (*GetTracepointInfoResponse) XXX_Size 

func (m *GetTracepointInfoResponse) XXX_Size() int

func (*GetTracepointInfoResponse) XXX_Unmarshal 

func (m *GetTracepointInfoResponse) XXX_Unmarshal(b []byte) error

type GetTracepointInfoResponse_TracepointState 

type GetTracepointInfoResponse_TracepointState struct {
	ID            *uuidpb.UUID            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State         statuspb.LifeCycleState `protobuf:"varint,2,opt,name=state,proto3,enum=px.statuspb.LifeCycleState" json:"state,omitempty"`
	Statuses      []*statuspb.Status      `protobuf:"bytes,3,rep,name=statuses,proto3" json:"statuses,omitempty"`
	Name          string                  `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	ExpectedState statuspb.LifeCycleState `` /* 133-byte string literal not displayed */
	SchemaNames   []string                `protobuf:"bytes,6,rep,name=schema_names,json=schemaNames,proto3" json:"schema_names,omitempty"`
}

func (*GetTracepointInfoResponse_TracepointState) Descriptor 

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

func (*GetTracepointInfoResponse_TracepointState) Equal 

func (this *GetTracepointInfoResponse_TracepointState) Equal(that interface{}) bool

func (*GetTracepointInfoResponse_TracepointState) GetExpectedState 

func (m *GetTracepointInfoResponse_TracepointState) GetExpectedState() statuspb.LifeCycleState

func (*GetTracepointInfoResponse_TracepointState) GetID 

func (m *GetTracepointInfoResponse_TracepointState) GetID() *uuidpb.UUID

func (*GetTracepointInfoResponse_TracepointState) GetName 

func (m *GetTracepointInfoResponse_TracepointState) GetName() string

func (*GetTracepointInfoResponse_TracepointState) GetSchemaNames 

func (m *GetTracepointInfoResponse_TracepointState) GetSchemaNames() []string

func (*GetTracepointInfoResponse_TracepointState) GetState 

func (m *GetTracepointInfoResponse_TracepointState) GetState() statuspb.LifeCycleState

func (*GetTracepointInfoResponse_TracepointState) GetStatuses 

func (m *GetTracepointInfoResponse_TracepointState) GetStatuses() []*statuspb.Status

func (*GetTracepointInfoResponse_TracepointState) GoString 

func (this *GetTracepointInfoResponse_TracepointState) GoString() string

func (*GetTracepointInfoResponse_TracepointState) Marshal 

func (m *GetTracepointInfoResponse_TracepointState) Marshal() (dAtA []byte, err error)

func (*GetTracepointInfoResponse_TracepointState) MarshalTo 

func (m *GetTracepointInfoResponse_TracepointState) MarshalTo(dAtA []byte) (int, error)

func (*GetTracepointInfoResponse_TracepointState) MarshalToSizedBuffer 

func (m *GetTracepointInfoResponse_TracepointState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTracepointInfoResponse_TracepointState) ProtoMessage 

func (*GetTracepointInfoResponse_TracepointState) ProtoMessage()

func (*GetTracepointInfoResponse_TracepointState) Reset 

func (m *GetTracepointInfoResponse_TracepointState) Reset()

func (*GetTracepointInfoResponse_TracepointState) Size 

func (m *GetTracepointInfoResponse_TracepointState) Size() (n int)

func (*GetTracepointInfoResponse_TracepointState) String 

func (this *GetTracepointInfoResponse_TracepointState) String() string

func (*GetTracepointInfoResponse_TracepointState) Unmarshal 

func (m *GetTracepointInfoResponse_TracepointState) Unmarshal(dAtA []byte) error

func (*GetTracepointInfoResponse_TracepointState) XXX_DiscardUnknown 

func (m *GetTracepointInfoResponse_TracepointState) XXX_DiscardUnknown()

func (*GetTracepointInfoResponse_TracepointState) XXX_Marshal 

func (m *GetTracepointInfoResponse_TracepointState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTracepointInfoResponse_TracepointState) XXX_Merge 

func (m *GetTracepointInfoResponse_TracepointState) XXX_Merge(src proto.Message)

func (*GetTracepointInfoResponse_TracepointState) XXX_Size 

func (m *GetTracepointInfoResponse_TracepointState) XXX_Size() int

func (*GetTracepointInfoResponse_TracepointState) XXX_Unmarshal 

func (m *GetTracepointInfoResponse_TracepointState) XXX_Unmarshal(b []byte) error

type MetadataConfigServiceClient 

type MetadataConfigServiceClient interface {
	UpdateConfig(ctx context.Context, in *UpdateConfigRequest, opts ...grpc.CallOption) (*UpdateConfigResponse, error)
}

MetadataConfigServiceClient is the client API for MetadataConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetadataConfigServiceClient 

func NewMetadataConfigServiceClient(cc *grpc.ClientConn) MetadataConfigServiceClient

type MetadataConfigServiceServer 

type MetadataConfigServiceServer interface {
	UpdateConfig(context.Context, *UpdateConfigRequest) (*UpdateConfigResponse, error)
}

MetadataConfigServiceServer is the server API for MetadataConfigService service.

type MetadataServiceClient 

type MetadataServiceClient interface {
	GetAgentUpdates(ctx context.Context, in *AgentUpdatesRequest, opts ...grpc.CallOption) (MetadataService_GetAgentUpdatesClient, error)
	GetSchemas(ctx context.Context, in *SchemaRequest, opts ...grpc.CallOption) (*SchemaResponse, error)
	GetAgentInfo(ctx context.Context, in *AgentInfoRequest, opts ...grpc.CallOption) (*AgentInfoResponse, error)
	GetWithPrefixKey(ctx context.Context, in *WithPrefixKeyRequest, opts ...grpc.CallOption) (*WithPrefixKeyResponse, error)
}

MetadataServiceClient is the client API for MetadataService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetadataServiceClient 

func NewMetadataServiceClient(cc *grpc.ClientConn) MetadataServiceClient

type MetadataServiceServer 

type MetadataServiceServer interface {
	GetAgentUpdates(*AgentUpdatesRequest, MetadataService_GetAgentUpdatesServer) error
	GetSchemas(context.Context, *SchemaRequest) (*SchemaResponse, error)
	GetAgentInfo(context.Context, *AgentInfoRequest) (*AgentInfoResponse, error)
	GetWithPrefixKey(context.Context, *WithPrefixKeyRequest) (*WithPrefixKeyResponse, error)
}

MetadataServiceServer is the server API for MetadataService service.

type MetadataService_GetAgentUpdatesClient 

type MetadataService_GetAgentUpdatesClient interface {
	Recv() (*AgentUpdatesResponse, error)
	grpc.ClientStream
}

type MetadataService_GetAgentUpdatesServer 

type MetadataService_GetAgentUpdatesServer interface {
	Send(*AgentUpdatesResponse) error
	grpc.ServerStream
}

type MetadataTracepointServiceClient 

type MetadataTracepointServiceClient interface {
	RegisterTracepoint(ctx context.Context, in *RegisterTracepointRequest, opts ...grpc.CallOption) (*RegisterTracepointResponse, error)
	GetTracepointInfo(ctx context.Context, in *GetTracepointInfoRequest, opts ...grpc.CallOption) (*GetTracepointInfoResponse, error)
	RemoveTracepoint(ctx context.Context, in *RemoveTracepointRequest, opts ...grpc.CallOption) (*RemoveTracepointResponse, error)
}

MetadataTracepointServiceClient is the client API for MetadataTracepointService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetadataTracepointServiceClient 

func NewMetadataTracepointServiceClient(cc *grpc.ClientConn) MetadataTracepointServiceClient

type MetadataTracepointServiceServer 

type MetadataTracepointServiceServer interface {
	RegisterTracepoint(context.Context, *RegisterTracepointRequest) (*RegisterTracepointResponse, error)
	GetTracepointInfo(context.Context, *GetTracepointInfoRequest) (*GetTracepointInfoResponse, error)
	RemoveTracepoint(context.Context, *RemoveTracepointRequest) (*RemoveTracepointResponse, error)
}

MetadataTracepointServiceServer is the server API for MetadataTracepointService service.

type RecordExecutionResultRequest 

type RecordExecutionResultRequest struct {
	ScriptID  *uuidpb.UUID     `protobuf:"bytes,1,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty"`
	Timestamp *types.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Types that are valid to be assigned to Result:
	//	*RecordExecutionResultRequest_Error
	//	*RecordExecutionResultRequest_ExecutionStats
	Result isRecordExecutionResultRequest_Result `protobuf_oneof:"result"`
}

func (*RecordExecutionResultRequest) Descriptor 

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

func (*RecordExecutionResultRequest) Equal 

func (this *RecordExecutionResultRequest) Equal(that interface{}) bool

func (*RecordExecutionResultRequest) GetError 

func (m *RecordExecutionResultRequest) GetError() *statuspb.Status

func (*RecordExecutionResultRequest) GetExecutionStats 

func (m *RecordExecutionResultRequest) GetExecutionStats() *ExecutionStats

func (*RecordExecutionResultRequest) GetResult 

func (m *RecordExecutionResultRequest) GetResult() isRecordExecutionResultRequest_Result

func (*RecordExecutionResultRequest) GetScriptID 

func (m *RecordExecutionResultRequest) GetScriptID() *uuidpb.UUID

func (*RecordExecutionResultRequest) GetTimestamp 

func (m *RecordExecutionResultRequest) GetTimestamp() *types.Timestamp

func (*RecordExecutionResultRequest) GoString 

func (this *RecordExecutionResultRequest) GoString() string

func (*RecordExecutionResultRequest) Marshal 

func (m *RecordExecutionResultRequest) Marshal() (dAtA []byte, err error)

func (*RecordExecutionResultRequest) MarshalTo 

func (m *RecordExecutionResultRequest) MarshalTo(dAtA []byte) (int, error)

func (*RecordExecutionResultRequest) MarshalToSizedBuffer 

func (m *RecordExecutionResultRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordExecutionResultRequest) ProtoMessage 

func (*RecordExecutionResultRequest) ProtoMessage()

func (*RecordExecutionResultRequest) Reset 

func (m *RecordExecutionResultRequest) Reset()

func (*RecordExecutionResultRequest) Size 

func (m *RecordExecutionResultRequest) Size() (n int)

func (*RecordExecutionResultRequest) String 

func (this *RecordExecutionResultRequest) String() string

func (*RecordExecutionResultRequest) Unmarshal 

func (m *RecordExecutionResultRequest) Unmarshal(dAtA []byte) error

func (*RecordExecutionResultRequest) XXX_DiscardUnknown 

func (m *RecordExecutionResultRequest) XXX_DiscardUnknown()

func (*RecordExecutionResultRequest) XXX_Marshal 

func (m *RecordExecutionResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordExecutionResultRequest) XXX_Merge 

func (m *RecordExecutionResultRequest) XXX_Merge(src proto.Message)

func (*RecordExecutionResultRequest) XXX_OneofWrappers 

func (*RecordExecutionResultRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*RecordExecutionResultRequest) XXX_Size 

func (m *RecordExecutionResultRequest) XXX_Size() int

func (*RecordExecutionResultRequest) XXX_Unmarshal 

func (m *RecordExecutionResultRequest) XXX_Unmarshal(b []byte) error

type RecordExecutionResultRequest_Error 

type RecordExecutionResultRequest_Error struct {
	Error *statuspb.Status `protobuf:"bytes,3,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

func (*RecordExecutionResultRequest_Error) Equal 

func (this *RecordExecutionResultRequest_Error) Equal(that interface{}) bool

func (*RecordExecutionResultRequest_Error) GoString 

func (this *RecordExecutionResultRequest_Error) GoString() string

func (*RecordExecutionResultRequest_Error) MarshalTo 

func (m *RecordExecutionResultRequest_Error) MarshalTo(dAtA []byte) (int, error)

func (*RecordExecutionResultRequest_Error) MarshalToSizedBuffer 

func (m *RecordExecutionResultRequest_Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordExecutionResultRequest_Error) Size 

func (m *RecordExecutionResultRequest_Error) Size() (n int)

func (*RecordExecutionResultRequest_Error) String 

func (this *RecordExecutionResultRequest_Error) String() string

type RecordExecutionResultRequest_ExecutionStats 

type RecordExecutionResultRequest_ExecutionStats struct {
	ExecutionStats *ExecutionStats `protobuf:"bytes,4,opt,name=execution_stats,json=executionStats,proto3,oneof" json:"execution_stats,omitempty"`
}

func (*RecordExecutionResultRequest_ExecutionStats) Equal 

func (this *RecordExecutionResultRequest_ExecutionStats) Equal(that interface{}) bool

func (*RecordExecutionResultRequest_ExecutionStats) GoString 

func (this *RecordExecutionResultRequest_ExecutionStats) GoString() string

func (*RecordExecutionResultRequest_ExecutionStats) MarshalTo 

func (m *RecordExecutionResultRequest_ExecutionStats) MarshalTo(dAtA []byte) (int, error)

func (*RecordExecutionResultRequest_ExecutionStats) MarshalToSizedBuffer 

func (m *RecordExecutionResultRequest_ExecutionStats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordExecutionResultRequest_ExecutionStats) Size 

func (m *RecordExecutionResultRequest_ExecutionStats) Size() (n int)

func (*RecordExecutionResultRequest_ExecutionStats) String 

func (this *RecordExecutionResultRequest_ExecutionStats) String() string

type RecordExecutionResultResponse 

type RecordExecutionResultResponse struct {
}

func (*RecordExecutionResultResponse) Descriptor 

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

func (*RecordExecutionResultResponse) Equal 

func (this *RecordExecutionResultResponse) Equal(that interface{}) bool

func (*RecordExecutionResultResponse) GoString 

func (this *RecordExecutionResultResponse) GoString() string

func (*RecordExecutionResultResponse) Marshal 

func (m *RecordExecutionResultResponse) Marshal() (dAtA []byte, err error)

func (*RecordExecutionResultResponse) MarshalTo 

func (m *RecordExecutionResultResponse) MarshalTo(dAtA []byte) (int, error)

func (*RecordExecutionResultResponse) MarshalToSizedBuffer 

func (m *RecordExecutionResultResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RecordExecutionResultResponse) ProtoMessage 

func (*RecordExecutionResultResponse) ProtoMessage()

func (*RecordExecutionResultResponse) Reset 

func (m *RecordExecutionResultResponse) Reset()

func (*RecordExecutionResultResponse) Size 

func (m *RecordExecutionResultResponse) Size() (n int)

func (*RecordExecutionResultResponse) String 

func (this *RecordExecutionResultResponse) String() string

func (*RecordExecutionResultResponse) Unmarshal 

func (m *RecordExecutionResultResponse) Unmarshal(dAtA []byte) error

func (*RecordExecutionResultResponse) XXX_DiscardUnknown 

func (m *RecordExecutionResultResponse) XXX_DiscardUnknown()

func (*RecordExecutionResultResponse) XXX_Marshal 

func (m *RecordExecutionResultResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordExecutionResultResponse) XXX_Merge 

func (m *RecordExecutionResultResponse) XXX_Merge(src proto.Message)

func (*RecordExecutionResultResponse) XXX_Size 

func (m *RecordExecutionResultResponse) XXX_Size() int

func (*RecordExecutionResultResponse) XXX_Unmarshal 

func (m *RecordExecutionResultResponse) XXX_Unmarshal(b []byte) error

type RegisterTracepointRequest 

type RegisterTracepointRequest struct {
	Requests []*RegisterTracepointRequest_TracepointRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
}

func (*RegisterTracepointRequest) Descriptor 

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

func (*RegisterTracepointRequest) Equal 

func (this *RegisterTracepointRequest) Equal(that interface{}) bool

func (*RegisterTracepointRequest) GetRequests 

func (m *RegisterTracepointRequest) GetRequests() []*RegisterTracepointRequest_TracepointRequest

func (*RegisterTracepointRequest) GoString 

func (this *RegisterTracepointRequest) GoString() string

func (*RegisterTracepointRequest) Marshal 

func (m *RegisterTracepointRequest) Marshal() (dAtA []byte, err error)

func (*RegisterTracepointRequest) MarshalTo 

func (m *RegisterTracepointRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterTracepointRequest) MarshalToSizedBuffer 

func (m *RegisterTracepointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterTracepointRequest) ProtoMessage 

func (*RegisterTracepointRequest) ProtoMessage()

func (*RegisterTracepointRequest) Reset 

func (m *RegisterTracepointRequest) Reset()

func (*RegisterTracepointRequest) Size 

func (m *RegisterTracepointRequest) Size() (n int)

func (*RegisterTracepointRequest) String 

func (this *RegisterTracepointRequest) String() string

func (*RegisterTracepointRequest) Unmarshal 

func (m *RegisterTracepointRequest) Unmarshal(dAtA []byte) error

func (*RegisterTracepointRequest) XXX_DiscardUnknown 

func (m *RegisterTracepointRequest) XXX_DiscardUnknown()

func (*RegisterTracepointRequest) XXX_Marshal 

func (m *RegisterTracepointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterTracepointRequest) XXX_Merge 

func (m *RegisterTracepointRequest) XXX_Merge(src proto.Message)

func (*RegisterTracepointRequest) XXX_Size 

func (m *RegisterTracepointRequest) XXX_Size() int

func (*RegisterTracepointRequest) XXX_Unmarshal 

func (m *RegisterTracepointRequest) XXX_Unmarshal(b []byte) error

type RegisterTracepointRequest_TracepointRequest 

type RegisterTracepointRequest_TracepointRequest struct {
	TracepointDeployment *logicalpb.TracepointDeployment `protobuf:"bytes,1,opt,name=tracepoint_deployment,json=tracepointDeployment,proto3" json:"tracepoint_deployment,omitempty"`
	Name                 string                          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	TTL                  *types.Duration                 `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
}

func (*RegisterTracepointRequest_TracepointRequest) Descriptor 

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

func (*RegisterTracepointRequest_TracepointRequest) Equal 

func (this *RegisterTracepointRequest_TracepointRequest) Equal(that interface{}) bool

func (*RegisterTracepointRequest_TracepointRequest) GetName 

func (m *RegisterTracepointRequest_TracepointRequest) GetName() string

func (*RegisterTracepointRequest_TracepointRequest) GetTTL 

func (m *RegisterTracepointRequest_TracepointRequest) GetTTL() *types.Duration

func (*RegisterTracepointRequest_TracepointRequest) GetTracepointDeployment 

func (m *RegisterTracepointRequest_TracepointRequest) GetTracepointDeployment() *logicalpb.TracepointDeployment

func (*RegisterTracepointRequest_TracepointRequest) GoString 

func (this *RegisterTracepointRequest_TracepointRequest) GoString() string

func (*RegisterTracepointRequest_TracepointRequest) Marshal 

func (m *RegisterTracepointRequest_TracepointRequest) Marshal() (dAtA []byte, err error)

func (*RegisterTracepointRequest_TracepointRequest) MarshalTo 

func (m *RegisterTracepointRequest_TracepointRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterTracepointRequest_TracepointRequest) MarshalToSizedBuffer 

func (m *RegisterTracepointRequest_TracepointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterTracepointRequest_TracepointRequest) ProtoMessage 

func (*RegisterTracepointRequest_TracepointRequest) ProtoMessage()

func (*RegisterTracepointRequest_TracepointRequest) Reset 

func (m *RegisterTracepointRequest_TracepointRequest) Reset()

func (*RegisterTracepointRequest_TracepointRequest) Size 

func (m *RegisterTracepointRequest_TracepointRequest) Size() (n int)

func (*RegisterTracepointRequest_TracepointRequest) String 

func (this *RegisterTracepointRequest_TracepointRequest) String() string

func (*RegisterTracepointRequest_TracepointRequest) Unmarshal 

func (m *RegisterTracepointRequest_TracepointRequest) Unmarshal(dAtA []byte) error

func (*RegisterTracepointRequest_TracepointRequest) XXX_DiscardUnknown 

func (m *RegisterTracepointRequest_TracepointRequest) XXX_DiscardUnknown()

func (*RegisterTracepointRequest_TracepointRequest) XXX_Marshal 

func (m *RegisterTracepointRequest_TracepointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterTracepointRequest_TracepointRequest) XXX_Merge 

func (m *RegisterTracepointRequest_TracepointRequest) XXX_Merge(src proto.Message)

func (*RegisterTracepointRequest_TracepointRequest) XXX_Size 

func (m *RegisterTracepointRequest_TracepointRequest) XXX_Size() int

func (*RegisterTracepointRequest_TracepointRequest) XXX_Unmarshal 

func (m *RegisterTracepointRequest_TracepointRequest) XXX_Unmarshal(b []byte) error

type RegisterTracepointResponse 

type RegisterTracepointResponse struct {
	Tracepoints []*RegisterTracepointResponse_TracepointStatus `protobuf:"bytes,1,rep,name=tracepoints,proto3" json:"tracepoints,omitempty"`
	Status      *statuspb.Status                               `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
}

func (*RegisterTracepointResponse) Descriptor 

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

func (*RegisterTracepointResponse) Equal 

func (this *RegisterTracepointResponse) Equal(that interface{}) bool

func (*RegisterTracepointResponse) GetStatus 

func (m *RegisterTracepointResponse) GetStatus() *statuspb.Status

func (*RegisterTracepointResponse) GetTracepoints 

func (m *RegisterTracepointResponse) GetTracepoints() []*RegisterTracepointResponse_TracepointStatus

func (*RegisterTracepointResponse) GoString 

func (this *RegisterTracepointResponse) GoString() string

func (*RegisterTracepointResponse) Marshal 

func (m *RegisterTracepointResponse) Marshal() (dAtA []byte, err error)

func (*RegisterTracepointResponse) MarshalTo 

func (m *RegisterTracepointResponse) MarshalTo(dAtA []byte) (int, error)

func (*RegisterTracepointResponse) MarshalToSizedBuffer 

func (m *RegisterTracepointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterTracepointResponse) ProtoMessage 

func (*RegisterTracepointResponse) ProtoMessage()

func (*RegisterTracepointResponse) Reset 

func (m *RegisterTracepointResponse) Reset()

func (*RegisterTracepointResponse) Size 

func (m *RegisterTracepointResponse) Size() (n int)

func (*RegisterTracepointResponse) String 

func (this *RegisterTracepointResponse) String() string

func (*RegisterTracepointResponse) Unmarshal 

func (m *RegisterTracepointResponse) Unmarshal(dAtA []byte) error

func (*RegisterTracepointResponse) XXX_DiscardUnknown 

func (m *RegisterTracepointResponse) XXX_DiscardUnknown()

func (*RegisterTracepointResponse) XXX_Marshal 

func (m *RegisterTracepointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterTracepointResponse) XXX_Merge 

func (m *RegisterTracepointResponse) XXX_Merge(src proto.Message)

func (*RegisterTracepointResponse) XXX_Size 

func (m *RegisterTracepointResponse) XXX_Size() int

func (*RegisterTracepointResponse) XXX_Unmarshal 

func (m *RegisterTracepointResponse) XXX_Unmarshal(b []byte) error

type RegisterTracepointResponse_TracepointStatus 

type RegisterTracepointResponse_TracepointStatus struct {
	Status *statuspb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ID     *uuidpb.UUID     `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Name   string           `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
}

func (*RegisterTracepointResponse_TracepointStatus) Descriptor 

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

func (*RegisterTracepointResponse_TracepointStatus) Equal 

func (this *RegisterTracepointResponse_TracepointStatus) Equal(that interface{}) bool

func (*RegisterTracepointResponse_TracepointStatus) GetID 

func (m *RegisterTracepointResponse_TracepointStatus) GetID() *uuidpb.UUID

func (*RegisterTracepointResponse_TracepointStatus) GetName 

func (m *RegisterTracepointResponse_TracepointStatus) GetName() string

func (*RegisterTracepointResponse_TracepointStatus) GetStatus 

func (m *RegisterTracepointResponse_TracepointStatus) GetStatus() *statuspb.Status

func (*RegisterTracepointResponse_TracepointStatus) GoString 

func (this *RegisterTracepointResponse_TracepointStatus) GoString() string

func (*RegisterTracepointResponse_TracepointStatus) Marshal 

func (m *RegisterTracepointResponse_TracepointStatus) Marshal() (dAtA []byte, err error)

func (*RegisterTracepointResponse_TracepointStatus) MarshalTo 

func (m *RegisterTracepointResponse_TracepointStatus) MarshalTo(dAtA []byte) (int, error)

func (*RegisterTracepointResponse_TracepointStatus) MarshalToSizedBuffer 

func (m *RegisterTracepointResponse_TracepointStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterTracepointResponse_TracepointStatus) ProtoMessage 

func (*RegisterTracepointResponse_TracepointStatus) ProtoMessage()

func (*RegisterTracepointResponse_TracepointStatus) Reset 

func (m *RegisterTracepointResponse_TracepointStatus) Reset()

func (*RegisterTracepointResponse_TracepointStatus) Size 

func (m *RegisterTracepointResponse_TracepointStatus) Size() (n int)

func (*RegisterTracepointResponse_TracepointStatus) String 

func (this *RegisterTracepointResponse_TracepointStatus) String() string

func (*RegisterTracepointResponse_TracepointStatus) Unmarshal 

func (m *RegisterTracepointResponse_TracepointStatus) Unmarshal(dAtA []byte) error

func (*RegisterTracepointResponse_TracepointStatus) XXX_DiscardUnknown 

func (m *RegisterTracepointResponse_TracepointStatus) XXX_DiscardUnknown()

func (*RegisterTracepointResponse_TracepointStatus) XXX_Marshal 

func (m *RegisterTracepointResponse_TracepointStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterTracepointResponse_TracepointStatus) XXX_Merge 

func (m *RegisterTracepointResponse_TracepointStatus) XXX_Merge(src proto.Message)

func (*RegisterTracepointResponse_TracepointStatus) XXX_Size 

func (m *RegisterTracepointResponse_TracepointStatus) XXX_Size() int

func (*RegisterTracepointResponse_TracepointStatus) XXX_Unmarshal 

func (m *RegisterTracepointResponse_TracepointStatus) XXX_Unmarshal(b []byte) error

type RemoveTracepointRequest 

type RemoveTracepointRequest struct {
	Names []string `protobuf:"bytes,1,rep,name=names,proto3" json:"names,omitempty"`
}

func (*RemoveTracepointRequest) Descriptor 

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

func (*RemoveTracepointRequest) Equal 

func (this *RemoveTracepointRequest) Equal(that interface{}) bool

func (*RemoveTracepointRequest) GetNames 

func (m *RemoveTracepointRequest) GetNames() []string

func (*RemoveTracepointRequest) GoString 

func (this *RemoveTracepointRequest) GoString() string

func (*RemoveTracepointRequest) Marshal 

func (m *RemoveTracepointRequest) Marshal() (dAtA []byte, err error)

func (*RemoveTracepointRequest) MarshalTo 

func (m *RemoveTracepointRequest) MarshalTo(dAtA []byte) (int, error)

func (*RemoveTracepointRequest) MarshalToSizedBuffer 

func (m *RemoveTracepointRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveTracepointRequest) ProtoMessage 

func (*RemoveTracepointRequest) ProtoMessage()

func (*RemoveTracepointRequest) Reset 

func (m *RemoveTracepointRequest) Reset()

func (*RemoveTracepointRequest) Size 

func (m *RemoveTracepointRequest) Size() (n int)

func (*RemoveTracepointRequest) String 

func (this *RemoveTracepointRequest) String() string

func (*RemoveTracepointRequest) Unmarshal 

func (m *RemoveTracepointRequest) Unmarshal(dAtA []byte) error

func (*RemoveTracepointRequest) XXX_DiscardUnknown 

func (m *RemoveTracepointRequest) XXX_DiscardUnknown()

func (*RemoveTracepointRequest) XXX_Marshal 

func (m *RemoveTracepointRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveTracepointRequest) XXX_Merge 

func (m *RemoveTracepointRequest) XXX_Merge(src proto.Message)

func (*RemoveTracepointRequest) XXX_Size 

func (m *RemoveTracepointRequest) XXX_Size() int

func (*RemoveTracepointRequest) XXX_Unmarshal 

func (m *RemoveTracepointRequest) XXX_Unmarshal(b []byte) error

type RemoveTracepointResponse 

type RemoveTracepointResponse struct {
	Status *statuspb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

func (*RemoveTracepointResponse) Descriptor 

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

func (*RemoveTracepointResponse) Equal 

func (this *RemoveTracepointResponse) Equal(that interface{}) bool

func (*RemoveTracepointResponse) GetStatus 

func (m *RemoveTracepointResponse) GetStatus() *statuspb.Status

func (*RemoveTracepointResponse) GoString 

func (this *RemoveTracepointResponse) GoString() string

func (*RemoveTracepointResponse) Marshal 

func (m *RemoveTracepointResponse) Marshal() (dAtA []byte, err error)

func (*RemoveTracepointResponse) MarshalTo 

func (m *RemoveTracepointResponse) MarshalTo(dAtA []byte) (int, error)

func (*RemoveTracepointResponse) MarshalToSizedBuffer 

func (m *RemoveTracepointResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveTracepointResponse) ProtoMessage 

func (*RemoveTracepointResponse) ProtoMessage()

func (*RemoveTracepointResponse) Reset 

func (m *RemoveTracepointResponse) Reset()

func (*RemoveTracepointResponse) Size 

func (m *RemoveTracepointResponse) Size() (n int)

func (*RemoveTracepointResponse) String 

func (this *RemoveTracepointResponse) String() string

func (*RemoveTracepointResponse) Unmarshal 

func (m *RemoveTracepointResponse) Unmarshal(dAtA []byte) error

func (*RemoveTracepointResponse) XXX_DiscardUnknown 

func (m *RemoveTracepointResponse) XXX_DiscardUnknown()

func (*RemoveTracepointResponse) XXX_Marshal 

func (m *RemoveTracepointResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveTracepointResponse) XXX_Merge 

func (m *RemoveTracepointResponse) XXX_Merge(src proto.Message)

func (*RemoveTracepointResponse) XXX_Size 

func (m *RemoveTracepointResponse) XXX_Size() int

func (*RemoveTracepointResponse) XXX_Unmarshal 

func (m *RemoveTracepointResponse) XXX_Unmarshal(b []byte) error

type SchemaRequest 

type SchemaRequest struct {
}

func (*SchemaRequest) Descriptor 

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

func (*SchemaRequest) Equal 

func (this *SchemaRequest) Equal(that interface{}) bool

func (*SchemaRequest) GoString 

func (this *SchemaRequest) GoString() string

func (*SchemaRequest) Marshal 

func (m *SchemaRequest) Marshal() (dAtA []byte, err error)

func (*SchemaRequest) MarshalTo 

func (m *SchemaRequest) MarshalTo(dAtA []byte) (int, error)

func (*SchemaRequest) MarshalToSizedBuffer 

func (m *SchemaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchemaRequest) ProtoMessage 

func (*SchemaRequest) ProtoMessage()

func (*SchemaRequest) Reset 

func (m *SchemaRequest) Reset()

func (*SchemaRequest) Size 

func (m *SchemaRequest) Size() (n int)

func (*SchemaRequest) String 

func (this *SchemaRequest) String() string

func (*SchemaRequest) Unmarshal 

func (m *SchemaRequest) Unmarshal(dAtA []byte) error

func (*SchemaRequest) XXX_DiscardUnknown 

func (m *SchemaRequest) XXX_DiscardUnknown()

func (*SchemaRequest) XXX_Marshal 

func (m *SchemaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemaRequest) XXX_Merge 

func (m *SchemaRequest) XXX_Merge(src proto.Message)

func (*SchemaRequest) XXX_Size 

func (m *SchemaRequest) XXX_Size() int

func (*SchemaRequest) XXX_Unmarshal 

func (m *SchemaRequest) XXX_Unmarshal(b []byte) error

type SchemaResponse 

type SchemaResponse struct {
	Schema *schemapb.Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
}

func (*SchemaResponse) Descriptor 

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

func (*SchemaResponse) Equal 

func (this *SchemaResponse) Equal(that interface{}) bool

func (*SchemaResponse) GetSchema 

func (m *SchemaResponse) GetSchema() *schemapb.Schema

func (*SchemaResponse) GoString 

func (this *SchemaResponse) GoString() string

func (*SchemaResponse) Marshal 

func (m *SchemaResponse) Marshal() (dAtA []byte, err error)

func (*SchemaResponse) MarshalTo 

func (m *SchemaResponse) MarshalTo(dAtA []byte) (int, error)

func (*SchemaResponse) MarshalToSizedBuffer 

func (m *SchemaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchemaResponse) ProtoMessage 

func (*SchemaResponse) ProtoMessage()

func (*SchemaResponse) Reset 

func (m *SchemaResponse) Reset()

func (*SchemaResponse) Size 

func (m *SchemaResponse) Size() (n int)

func (*SchemaResponse) String 

func (this *SchemaResponse) String() string

func (*SchemaResponse) Unmarshal 

func (m *SchemaResponse) Unmarshal(dAtA []byte) error

func (*SchemaResponse) XXX_DiscardUnknown 

func (m *SchemaResponse) XXX_DiscardUnknown()

func (*SchemaResponse) XXX_Marshal 

func (m *SchemaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemaResponse) XXX_Merge 

func (m *SchemaResponse) XXX_Merge(src proto.Message)

func (*SchemaResponse) XXX_Size 

func (m *SchemaResponse) XXX_Size() int

func (*SchemaResponse) XXX_Unmarshal 

func (m *SchemaResponse) XXX_Unmarshal(b []byte) error

type SetScriptsRequest 

type SetScriptsRequest struct {
	Scripts map[string]*cvmsgspb.CronScript `` /* 155-byte string literal not displayed */
}

func (*SetScriptsRequest) Descriptor 

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

func (*SetScriptsRequest) Equal 

func (this *SetScriptsRequest) Equal(that interface{}) bool

func (*SetScriptsRequest) GetScripts 

func (m *SetScriptsRequest) GetScripts() map[string]*cvmsgspb.CronScript

func (*SetScriptsRequest) GoString 

func (this *SetScriptsRequest) GoString() string

func (*SetScriptsRequest) Marshal 

func (m *SetScriptsRequest) Marshal() (dAtA []byte, err error)

func (*SetScriptsRequest) MarshalTo 

func (m *SetScriptsRequest) MarshalTo(dAtA []byte) (int, error)

func (*SetScriptsRequest) MarshalToSizedBuffer 

func (m *SetScriptsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetScriptsRequest) ProtoMessage 

func (*SetScriptsRequest) ProtoMessage()

func (*SetScriptsRequest) Reset 

func (m *SetScriptsRequest) Reset()

func (*SetScriptsRequest) Size 

func (m *SetScriptsRequest) Size() (n int)

func (*SetScriptsRequest) String 

func (this *SetScriptsRequest) String() string

func (*SetScriptsRequest) Unmarshal 

func (m *SetScriptsRequest) Unmarshal(dAtA []byte) error

func (*SetScriptsRequest) XXX_DiscardUnknown 

func (m *SetScriptsRequest) XXX_DiscardUnknown()

func (*SetScriptsRequest) XXX_Marshal 

func (m *SetScriptsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetScriptsRequest) XXX_Merge 

func (m *SetScriptsRequest) XXX_Merge(src proto.Message)

func (*SetScriptsRequest) XXX_Size 

func (m *SetScriptsRequest) XXX_Size() int

func (*SetScriptsRequest) XXX_Unmarshal 

func (m *SetScriptsRequest) XXX_Unmarshal(b []byte) error

type SetScriptsResponse 

type SetScriptsResponse struct {
}

func (*SetScriptsResponse) Descriptor 

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

func (*SetScriptsResponse) Equal 

func (this *SetScriptsResponse) Equal(that interface{}) bool

func (*SetScriptsResponse) GoString 

func (this *SetScriptsResponse) GoString() string

func (*SetScriptsResponse) Marshal 

func (m *SetScriptsResponse) Marshal() (dAtA []byte, err error)

func (*SetScriptsResponse) MarshalTo 

func (m *SetScriptsResponse) MarshalTo(dAtA []byte) (int, error)

func (*SetScriptsResponse) MarshalToSizedBuffer 

func (m *SetScriptsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetScriptsResponse) ProtoMessage 

func (*SetScriptsResponse) ProtoMessage()

func (*SetScriptsResponse) Reset 

func (m *SetScriptsResponse) Reset()

func (*SetScriptsResponse) Size 

func (m *SetScriptsResponse) Size() (n int)

func (*SetScriptsResponse) String 

func (this *SetScriptsResponse) String() string

func (*SetScriptsResponse) Unmarshal 

func (m *SetScriptsResponse) Unmarshal(dAtA []byte) error

func (*SetScriptsResponse) XXX_DiscardUnknown 

func (m *SetScriptsResponse) XXX_DiscardUnknown()

func (*SetScriptsResponse) XXX_Marshal 

func (m *SetScriptsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetScriptsResponse) XXX_Merge 

func (m *SetScriptsResponse) XXX_Merge(src proto.Message)

func (*SetScriptsResponse) XXX_Size 

func (m *SetScriptsResponse) XXX_Size() int

func (*SetScriptsResponse) XXX_Unmarshal 

func (m *SetScriptsResponse) XXX_Unmarshal(b []byte) error

type UnimplementedCronScriptStoreServiceServer 

type UnimplementedCronScriptStoreServiceServer struct {
}

UnimplementedCronScriptStoreServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedCronScriptStoreServiceServer) AddOrUpdateScript 

func (*UnimplementedCronScriptStoreServiceServer) AddOrUpdateScript(ctx context.Context, req *AddOrUpdateScriptRequest) (*AddOrUpdateScriptResponse, error)

func (*UnimplementedCronScriptStoreServiceServer) DeleteScript 

func (*UnimplementedCronScriptStoreServiceServer) DeleteScript(ctx context.Context, req *DeleteScriptRequest) (*DeleteScriptResponse, error)

func (*UnimplementedCronScriptStoreServiceServer) GetAllExecutionResults 

func (*UnimplementedCronScriptStoreServiceServer) GetAllExecutionResults(ctx context.Context, req *GetAllExecutionResultsRequest) (*GetAllExecutionResultsResponse, error)

func (*UnimplementedCronScriptStoreServiceServer) GetScripts 

func (*UnimplementedCronScriptStoreServiceServer) GetScripts(ctx context.Context, req *GetScriptsRequest) (*GetScriptsResponse, error)

func (*UnimplementedCronScriptStoreServiceServer) RecordExecutionResult 

func (*UnimplementedCronScriptStoreServiceServer) RecordExecutionResult(ctx context.Context, req *RecordExecutionResultRequest) (*RecordExecutionResultResponse, error)

func (*UnimplementedCronScriptStoreServiceServer) SetScripts 

func (*UnimplementedCronScriptStoreServiceServer) SetScripts(ctx context.Context, req *SetScriptsRequest) (*SetScriptsResponse, error)

type UnimplementedMetadataConfigServiceServer 

type UnimplementedMetadataConfigServiceServer struct {
}

UnimplementedMetadataConfigServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataConfigServiceServer) UpdateConfig 

func (*UnimplementedMetadataConfigServiceServer) UpdateConfig(ctx context.Context, req *UpdateConfigRequest) (*UpdateConfigResponse, error)

type UnimplementedMetadataServiceServer 

type UnimplementedMetadataServiceServer struct {
}

UnimplementedMetadataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataServiceServer) GetAgentInfo 

func (*UnimplementedMetadataServiceServer) GetAgentInfo(ctx context.Context, req *AgentInfoRequest) (*AgentInfoResponse, error)

func (*UnimplementedMetadataServiceServer) GetAgentUpdates 

func (*UnimplementedMetadataServiceServer) GetAgentUpdates(req *AgentUpdatesRequest, srv MetadataService_GetAgentUpdatesServer) error

func (*UnimplementedMetadataServiceServer) GetSchemas 

func (*UnimplementedMetadataServiceServer) GetSchemas(ctx context.Context, req *SchemaRequest) (*SchemaResponse, error)

func (*UnimplementedMetadataServiceServer) GetWithPrefixKey 

func (*UnimplementedMetadataServiceServer) GetWithPrefixKey(ctx context.Context, req *WithPrefixKeyRequest) (*WithPrefixKeyResponse, error)

type UnimplementedMetadataTracepointServiceServer 

type UnimplementedMetadataTracepointServiceServer struct {
}

UnimplementedMetadataTracepointServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetadataTracepointServiceServer) GetTracepointInfo 

func (*UnimplementedMetadataTracepointServiceServer) GetTracepointInfo(ctx context.Context, req *GetTracepointInfoRequest) (*GetTracepointInfoResponse, error)

func (*UnimplementedMetadataTracepointServiceServer) RegisterTracepoint 

func (*UnimplementedMetadataTracepointServiceServer) RegisterTracepoint(ctx context.Context, req *RegisterTracepointRequest) (*RegisterTracepointResponse, error)

func (*UnimplementedMetadataTracepointServiceServer) RemoveTracepoint 

func (*UnimplementedMetadataTracepointServiceServer) RemoveTracepoint(ctx context.Context, req *RemoveTracepointRequest) (*RemoveTracepointResponse, error)

type UpdateConfigRequest 

type UpdateConfigRequest 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"`
	AgentPodName string `protobuf:"bytes,3,opt,name=agent_pod_name,json=agentPodName,proto3" json:"agent_pod_name,omitempty"`
}

func (*UpdateConfigRequest) Descriptor 

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

func (*UpdateConfigRequest) Equal 

func (this *UpdateConfigRequest) Equal(that interface{}) bool

func (*UpdateConfigRequest) GetAgentPodName 

func (m *UpdateConfigRequest) GetAgentPodName() string

func (*UpdateConfigRequest) GetKey 

func (m *UpdateConfigRequest) GetKey() string

func (*UpdateConfigRequest) GetValue 

func (m *UpdateConfigRequest) GetValue() string

func (*UpdateConfigRequest) GoString 

func (this *UpdateConfigRequest) GoString() string

func (*UpdateConfigRequest) Marshal 

func (m *UpdateConfigRequest) Marshal() (dAtA []byte, err error)

func (*UpdateConfigRequest) MarshalTo 

func (m *UpdateConfigRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateConfigRequest) MarshalToSizedBuffer 

func (m *UpdateConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateConfigRequest) ProtoMessage 

func (*UpdateConfigRequest) ProtoMessage()

func (*UpdateConfigRequest) Reset 

func (m *UpdateConfigRequest) Reset()

func (*UpdateConfigRequest) Size 

func (m *UpdateConfigRequest) Size() (n int)

func (*UpdateConfigRequest) String 

func (this *UpdateConfigRequest) String() string

func (*UpdateConfigRequest) Unmarshal 

func (m *UpdateConfigRequest) Unmarshal(dAtA []byte) error

func (*UpdateConfigRequest) XXX_DiscardUnknown 

func (m *UpdateConfigRequest) XXX_DiscardUnknown()

func (*UpdateConfigRequest) XXX_Marshal 

func (m *UpdateConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateConfigRequest) XXX_Merge 

func (m *UpdateConfigRequest) XXX_Merge(src proto.Message)

func (*UpdateConfigRequest) XXX_Size 

func (m *UpdateConfigRequest) XXX_Size() int

func (*UpdateConfigRequest) XXX_Unmarshal 

func (m *UpdateConfigRequest) XXX_Unmarshal(b []byte) error

type UpdateConfigResponse 

type UpdateConfigResponse struct {
	Status *statuspb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

func (*UpdateConfigResponse) Descriptor 

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

func (*UpdateConfigResponse) Equal 

func (this *UpdateConfigResponse) Equal(that interface{}) bool

func (*UpdateConfigResponse) GetStatus 

func (m *UpdateConfigResponse) GetStatus() *statuspb.Status

func (*UpdateConfigResponse) GoString 

func (this *UpdateConfigResponse) GoString() string

func (*UpdateConfigResponse) Marshal 

func (m *UpdateConfigResponse) Marshal() (dAtA []byte, err error)

func (*UpdateConfigResponse) MarshalTo 

func (m *UpdateConfigResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateConfigResponse) MarshalToSizedBuffer 

func (m *UpdateConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateConfigResponse) ProtoMessage 

func (*UpdateConfigResponse) ProtoMessage()

func (*UpdateConfigResponse) Reset 

func (m *UpdateConfigResponse) Reset()

func (*UpdateConfigResponse) Size 

func (m *UpdateConfigResponse) Size() (n int)

func (*UpdateConfigResponse) String 

func (this *UpdateConfigResponse) String() string

func (*UpdateConfigResponse) Unmarshal 

func (m *UpdateConfigResponse) Unmarshal(dAtA []byte) error

func (*UpdateConfigResponse) XXX_DiscardUnknown 

func (m *UpdateConfigResponse) XXX_DiscardUnknown()

func (*UpdateConfigResponse) XXX_Marshal 

func (m *UpdateConfigResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateConfigResponse) XXX_Merge 

func (m *UpdateConfigResponse) XXX_Merge(src proto.Message)

func (*UpdateConfigResponse) XXX_Size 

func (m *UpdateConfigResponse) XXX_Size() int

func (*UpdateConfigResponse) XXX_Unmarshal 

func (m *UpdateConfigResponse) XXX_Unmarshal(b []byte) error

type WithPrefixKeyRequest 

type WithPrefixKeyRequest struct {
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Proto  string `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
}

func (*WithPrefixKeyRequest) Descriptor 

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

func (*WithPrefixKeyRequest) Equal 

func (this *WithPrefixKeyRequest) Equal(that interface{}) bool

func (*WithPrefixKeyRequest) GetPrefix 

func (m *WithPrefixKeyRequest) GetPrefix() string

func (*WithPrefixKeyRequest) GetProto 

func (m *WithPrefixKeyRequest) GetProto() string

func (*WithPrefixKeyRequest) GoString 

func (this *WithPrefixKeyRequest) GoString() string

func (*WithPrefixKeyRequest) Marshal 

func (m *WithPrefixKeyRequest) Marshal() (dAtA []byte, err error)

func (*WithPrefixKeyRequest) MarshalTo 

func (m *WithPrefixKeyRequest) MarshalTo(dAtA []byte) (int, error)

func (*WithPrefixKeyRequest) MarshalToSizedBuffer 

func (m *WithPrefixKeyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WithPrefixKeyRequest) ProtoMessage 

func (*WithPrefixKeyRequest) ProtoMessage()

func (*WithPrefixKeyRequest) Reset 

func (m *WithPrefixKeyRequest) Reset()

func (*WithPrefixKeyRequest) Size 

func (m *WithPrefixKeyRequest) Size() (n int)

func (*WithPrefixKeyRequest) String 

func (this *WithPrefixKeyRequest) String() string

func (*WithPrefixKeyRequest) Unmarshal 

func (m *WithPrefixKeyRequest) Unmarshal(dAtA []byte) error

func (*WithPrefixKeyRequest) XXX_DiscardUnknown 

func (m *WithPrefixKeyRequest) XXX_DiscardUnknown()

func (*WithPrefixKeyRequest) XXX_Marshal 

func (m *WithPrefixKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WithPrefixKeyRequest) XXX_Merge 

func (m *WithPrefixKeyRequest) XXX_Merge(src proto.Message)

func (*WithPrefixKeyRequest) XXX_Size 

func (m *WithPrefixKeyRequest) XXX_Size() int

func (*WithPrefixKeyRequest) XXX_Unmarshal 

func (m *WithPrefixKeyRequest) XXX_Unmarshal(b []byte) error

type WithPrefixKeyResponse 

type WithPrefixKeyResponse struct {
	Kvs []*WithPrefixKeyResponse_KV `protobuf:"bytes,1,rep,name=kvs,proto3" json:"kvs,omitempty"`
}

func (*WithPrefixKeyResponse) Descriptor 

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

func (*WithPrefixKeyResponse) Equal 

func (this *WithPrefixKeyResponse) Equal(that interface{}) bool

func (*WithPrefixKeyResponse) GetKvs 

func (m *WithPrefixKeyResponse) GetKvs() []*WithPrefixKeyResponse_KV

func (*WithPrefixKeyResponse) GoString 

func (this *WithPrefixKeyResponse) GoString() string

func (*WithPrefixKeyResponse) Marshal 

func (m *WithPrefixKeyResponse) Marshal() (dAtA []byte, err error)

func (*WithPrefixKeyResponse) MarshalTo 

func (m *WithPrefixKeyResponse) MarshalTo(dAtA []byte) (int, error)

func (*WithPrefixKeyResponse) MarshalToSizedBuffer 

func (m *WithPrefixKeyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WithPrefixKeyResponse) ProtoMessage 

func (*WithPrefixKeyResponse) ProtoMessage()

func (*WithPrefixKeyResponse) Reset 

func (m *WithPrefixKeyResponse) Reset()

func (*WithPrefixKeyResponse) Size 

func (m *WithPrefixKeyResponse) Size() (n int)

func (*WithPrefixKeyResponse) String 

func (this *WithPrefixKeyResponse) String() string

func (*WithPrefixKeyResponse) Unmarshal 

func (m *WithPrefixKeyResponse) Unmarshal(dAtA []byte) error

func (*WithPrefixKeyResponse) XXX_DiscardUnknown 

func (m *WithPrefixKeyResponse) XXX_DiscardUnknown()

func (*WithPrefixKeyResponse) XXX_Marshal 

func (m *WithPrefixKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WithPrefixKeyResponse) XXX_Merge 

func (m *WithPrefixKeyResponse) XXX_Merge(src proto.Message)

func (*WithPrefixKeyResponse) XXX_Size 

func (m *WithPrefixKeyResponse) XXX_Size() int

func (*WithPrefixKeyResponse) XXX_Unmarshal 

func (m *WithPrefixKeyResponse) XXX_Unmarshal(b []byte) error

type WithPrefixKeyResponse_KV 

type WithPrefixKeyResponse_KV struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*WithPrefixKeyResponse_KV) Descriptor 

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

func (*WithPrefixKeyResponse_KV) Equal 

func (this *WithPrefixKeyResponse_KV) Equal(that interface{}) bool

func (*WithPrefixKeyResponse_KV) GetKey 

func (m *WithPrefixKeyResponse_KV) GetKey() string

func (*WithPrefixKeyResponse_KV) GetValue 

func (m *WithPrefixKeyResponse_KV) GetValue() []byte

func (*WithPrefixKeyResponse_KV) GoString 

func (this *WithPrefixKeyResponse_KV) GoString() string

func (*WithPrefixKeyResponse_KV) Marshal 

func (m *WithPrefixKeyResponse_KV) Marshal() (dAtA []byte, err error)

func (*WithPrefixKeyResponse_KV) MarshalTo 

func (m *WithPrefixKeyResponse_KV) MarshalTo(dAtA []byte) (int, error)

func (*WithPrefixKeyResponse_KV) MarshalToSizedBuffer 

func (m *WithPrefixKeyResponse_KV) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WithPrefixKeyResponse_KV) ProtoMessage 

func (*WithPrefixKeyResponse_KV) ProtoMessage()

func (*WithPrefixKeyResponse_KV) Reset 

func (m *WithPrefixKeyResponse_KV) Reset()

func (*WithPrefixKeyResponse_KV) Size 

func (m *WithPrefixKeyResponse_KV) Size() (n int)

func (*WithPrefixKeyResponse_KV) String 

func (this *WithPrefixKeyResponse_KV) String() string

func (*WithPrefixKeyResponse_KV) Unmarshal 

func (m *WithPrefixKeyResponse_KV) Unmarshal(dAtA []byte) error

func (*WithPrefixKeyResponse_KV) XXX_DiscardUnknown 

func (m *WithPrefixKeyResponse_KV) XXX_DiscardUnknown()

func (*WithPrefixKeyResponse_KV) XXX_Marshal 

func (m *WithPrefixKeyResponse_KV) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WithPrefixKeyResponse_KV) XXX_Merge 

func (m *WithPrefixKeyResponse_KV) XXX_Merge(src proto.Message)

func (*WithPrefixKeyResponse_KV) XXX_Size 

func (m *WithPrefixKeyResponse_KV) XXX_Size() int

func (*WithPrefixKeyResponse_KV) XXX_Unmarshal 

func (m *WithPrefixKeyResponse_KV) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis
Package mock_metadatapb is a generated GoMock package.
 Package mock_metadatapb is a generated GoMock package.

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.