agent

Apr 26, 2022

Changes in this version

+ var File_agent_proto protoreflect.FileDescriptor

+ var Response_ResponseStatus_name = map[int32]string

+ var Response_ResponseStatus_value = map[string]int32

+ var StreamResponse_ResponseType_name = map[int32]string

+ var StreamResponse_ResponseType_value = map[string]int32

+ var StreamingStore_ServiceDesc = grpc.ServiceDesc

+ func RegisterStreamingStoreServer(s grpc.ServiceRegistrar, srv StreamingStoreServer)

+ type AppInfo struct

+ Name string

+ Uuid string

+ func (*AppInfo) Descriptor() ([]byte, []int)

+ func (*AppInfo) ProtoMessage()

+ func (x *AppInfo) GetName() string

+ func (x *AppInfo) GetUuid() string

+ func (x *AppInfo) ProtoReflect() protoreflect.Message

+ func (x *AppInfo) Reset()

+ func (x *AppInfo) String() string

+ type Response struct

+ Details *structpb.Struct

+ Message string

+ Status Response_ResponseStatus

+ func (*Response) Descriptor() ([]byte, []int)

+ func (*Response) ProtoMessage()

+ func (x *Response) GetDetails() *structpb.Struct

+ func (x *Response) GetMessage() string

+ func (x *Response) GetStatus() Response_ResponseStatus

+ func (x *Response) ProtoReflect() protoreflect.Message

+ func (x *Response) Reset()

+ func (x *Response) String() string

+ type Response_ResponseStatus int32

+ const Response_ERROR

+ const Response_SUCCESS

+ const Response_SUCCESS_WITH_ERROR

+ func (Response_ResponseStatus) Descriptor() protoreflect.EnumDescriptor

+ func (Response_ResponseStatus) EnumDescriptor() ([]byte, []int)

+ func (Response_ResponseStatus) Type() protoreflect.EnumType

+ func (x Response_ResponseStatus) Enum() *Response_ResponseStatus

+ func (x Response_ResponseStatus) Number() protoreflect.EnumNumber

+ func (x Response_ResponseStatus) String() string

+ type StreamResponse struct

+ Message *structpb.Struct

+ Type StreamResponse_ResponseType

+ func (*StreamResponse) Descriptor() ([]byte, []int)

+ func (*StreamResponse) ProtoMessage()

+ func (x *StreamResponse) GetMessage() *structpb.Struct

+ func (x *StreamResponse) GetType() StreamResponse_ResponseType

+ func (x *StreamResponse) ProtoReflect() protoreflect.Message

+ func (x *StreamResponse) Reset()

+ func (x *StreamResponse) String() string

+ type StreamResponse_ResponseType int32

+ const StreamResponse_JOB_NOTIFICATION_INIT

+ const StreamResponse_JOB_NOTIFICATION_RELOAD

+ const StreamResponse_JOB_NOTIFICATION_START

+ func (StreamResponse_ResponseType) Descriptor() protoreflect.EnumDescriptor

+ func (StreamResponse_ResponseType) EnumDescriptor() ([]byte, []int)

+ func (StreamResponse_ResponseType) Type() protoreflect.EnumType

+ func (x StreamResponse_ResponseType) Enum() *StreamResponse_ResponseType

+ func (x StreamResponse_ResponseType) Number() protoreflect.EnumNumber

+ func (x StreamResponse_ResponseType) String() string

+ type StreamingStoreClient interface

+ SetupAppStream func(ctx context.Context, in *AppInfo, opts ...grpc.CallOption) (StreamingStore_SetupAppStreamClient, error)

+ func NewStreamingStoreClient(cc grpc.ClientConnInterface) StreamingStoreClient

+ type StreamingStoreServer interface

+ SetupAppStream func(*AppInfo, StreamingStore_SetupAppStreamServer) error

+ type StreamingStore_SetupAppStreamClient interface

+ Recv func() (*StreamResponse, error)

+ type StreamingStore_SetupAppStreamServer interface

+ Send func(*StreamResponse) error

+ type UnimplementedStreamingStoreServer struct

+ func (UnimplementedStreamingStoreServer) SetupAppStream(*AppInfo, StreamingStore_SetupAppStreamServer) error

+ type UnsafeStreamingStoreServer interface