agentrpc

package
v0.0.8 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2020 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_agentrpc_agentrpc_proto protoreflect.FileDescriptor

Functions

func RegisterKasServer 

func RegisterKasServer(s *grpc.Server, srv KasServer)

Types

type ConfigurationRequest 

type ConfigurationRequest struct {
	CommitId string `protobuf:"bytes,1,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationRequest) Descriptor deprecated 

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

Deprecated: Use ConfigurationRequest.ProtoReflect.Descriptor instead.

func (*ConfigurationRequest) GetCommitId added in v0.0.5 

func (x *ConfigurationRequest) GetCommitId() string

func (*ConfigurationRequest) ProtoMessage 

func (*ConfigurationRequest) ProtoMessage()

func (*ConfigurationRequest) ProtoReflect 

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

func (*ConfigurationRequest) Reset 

func (x *ConfigurationRequest) Reset()

func (*ConfigurationRequest) String 

func (x *ConfigurationRequest) String() string

type ConfigurationResponse 

type ConfigurationResponse struct {
	Configuration *agentcfg.AgentConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	CommitId      string                       `protobuf:"bytes,2,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use ConfigurationResponse.ProtoReflect.Descriptor instead.

func (*ConfigurationResponse) GetCommitId added in v0.0.5 

func (x *ConfigurationResponse) GetCommitId() string

func (*ConfigurationResponse) GetConfiguration 

func (x *ConfigurationResponse) GetConfiguration() *agentcfg.AgentConfiguration

func (*ConfigurationResponse) ProtoMessage 

func (*ConfigurationResponse) ProtoMessage()

func (*ConfigurationResponse) ProtoReflect 

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

func (*ConfigurationResponse) Reset 

func (x *ConfigurationResponse) Reset()

func (*ConfigurationResponse) String 

func (x *ConfigurationResponse) String() string

type KasClient 

type KasClient interface {
	GetConfiguration(ctx context.Context, in *ConfigurationRequest, opts ...grpc.CallOption) (Kas_GetConfigurationClient, error)
	GetObjectsToSynchronize(ctx context.Context, in *ObjectsToSynchronizeRequest, opts ...grpc.CallOption) (Kas_GetObjectsToSynchronizeClient, error)
}

KasClient is the client API for Kas service.

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

func NewKasClient 

func NewKasClient(cc grpc.ClientConnInterface) KasClient

type KasServer 

type KasServer interface {
	GetConfiguration(*ConfigurationRequest, Kas_GetConfigurationServer) error
	GetObjectsToSynchronize(*ObjectsToSynchronizeRequest, Kas_GetObjectsToSynchronizeServer) error
}

KasServer is the server API for Kas service.

type Kas_GetConfigurationClient 

type Kas_GetConfigurationClient interface {
	Recv() (*ConfigurationResponse, error)
	grpc.ClientStream
}

type Kas_GetConfigurationServer 

type Kas_GetConfigurationServer interface {
	Send(*ConfigurationResponse) error
	grpc.ServerStream
}

type Kas_GetObjectsToSynchronizeClient 

type Kas_GetObjectsToSynchronizeClient interface {
	Recv() (*ObjectsToSynchronizeResponse, error)
	grpc.ClientStream
}

type Kas_GetObjectsToSynchronizeServer 

type Kas_GetObjectsToSynchronizeServer interface {
	Send(*ObjectsToSynchronizeResponse) error
	grpc.ServerStream
}

type ObjectToSynchronize 

type ObjectToSynchronize struct {
	Object []byte `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectToSynchronize) Descriptor deprecated 

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

Deprecated: Use ObjectToSynchronize.ProtoReflect.Descriptor instead.

func (*ObjectToSynchronize) GetObject 

func (x *ObjectToSynchronize) GetObject() []byte

func (*ObjectToSynchronize) GetSource 

func (x *ObjectToSynchronize) GetSource() string

func (*ObjectToSynchronize) ProtoMessage 

func (*ObjectToSynchronize) ProtoMessage()

func (*ObjectToSynchronize) ProtoReflect 

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

func (*ObjectToSynchronize) Reset 

func (x *ObjectToSynchronize) Reset()

func (*ObjectToSynchronize) String 

func (x *ObjectToSynchronize) String() string

type ObjectsToSynchronizeRequest 

type ObjectsToSynchronizeRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	CommitId  string `protobuf:"bytes,2,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectsToSynchronizeRequest) Descriptor deprecated 

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

Deprecated: Use ObjectsToSynchronizeRequest.ProtoReflect.Descriptor instead.

func (*ObjectsToSynchronizeRequest) GetCommitId added in v0.0.5 

func (x *ObjectsToSynchronizeRequest) GetCommitId() string

func (*ObjectsToSynchronizeRequest) GetProjectId 

func (x *ObjectsToSynchronizeRequest) GetProjectId() string

func (*ObjectsToSynchronizeRequest) ProtoMessage 

func (*ObjectsToSynchronizeRequest) ProtoMessage()

func (*ObjectsToSynchronizeRequest) ProtoReflect 

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

func (*ObjectsToSynchronizeRequest) Reset 

func (x *ObjectsToSynchronizeRequest) Reset()

func (*ObjectsToSynchronizeRequest) String 

func (x *ObjectsToSynchronizeRequest) String() string

type ObjectsToSynchronizeResponse 

type ObjectsToSynchronizeResponse struct {
	CommitId string                 `protobuf:"bytes,1,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
	Objects  []*ObjectToSynchronize `protobuf:"bytes,2,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectsToSynchronizeResponse) Descriptor deprecated 

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

Deprecated: Use ObjectsToSynchronizeResponse.ProtoReflect.Descriptor instead.

func (*ObjectsToSynchronizeResponse) GetCommitId added in v0.0.5 

func (x *ObjectsToSynchronizeResponse) GetCommitId() string

func (*ObjectsToSynchronizeResponse) GetObjects 

func (x *ObjectsToSynchronizeResponse) GetObjects() []*ObjectToSynchronize

func (*ObjectsToSynchronizeResponse) ProtoMessage 

func (*ObjectsToSynchronizeResponse) ProtoMessage()

func (*ObjectsToSynchronizeResponse) ProtoReflect 

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

func (*ObjectsToSynchronizeResponse) Reset 

func (x *ObjectsToSynchronizeResponse) Reset()

func (*ObjectsToSynchronizeResponse) String 

func (x *ObjectsToSynchronizeResponse) String() string

type UnimplementedKasServer 

type UnimplementedKasServer struct {
}

UnimplementedKasServer can be embedded to have forward compatible implementations.

func (*UnimplementedKasServer) GetConfiguration 

func (*UnimplementedKasServer) GetConfiguration(*ConfigurationRequest, Kas_GetConfigurationServer) error

func (*UnimplementedKasServer) GetObjectsToSynchronize 

func (*UnimplementedKasServer) GetObjectsToSynchronize(*ObjectsToSynchronizeRequest, Kas_GetObjectsToSynchronizeServer) error

Source Files

View all Source files

Directories

Path Synopsis
Package mock_agentrpc is a generated GoMock package.
 Package mock_agentrpc 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.