agent

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Dec 15, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	StreamResponse_ResponseType_name = map[int32]string{
		0: "JOB_NOTIFICATION_INIT",
		1: "JOB_NOTIFICATION_START",
		2: "JOB_NOTIFICATION_RELOAD",
	}
	StreamResponse_ResponseType_value = map[string]int32{
		"JOB_NOTIFICATION_INIT":   0,
		"JOB_NOTIFICATION_START":  1,
		"JOB_NOTIFICATION_RELOAD": 2,
	}
)

Enum value maps for StreamResponse_ResponseType.

View Source 
var (
	Response_ResponseStatus_name = map[int32]string{
		0: "ERROR",
		1: "SUCCESS",
		2: "SUCCESS_WITH_ERROR",
	}
	Response_ResponseStatus_value = map[string]int32{
		"ERROR":              0,
		"SUCCESS":            1,
		"SUCCESS_WITH_ERROR": 2,
	}
)

Enum value maps for Response_ResponseStatus.

View Source 
var File_agent_proto protoreflect.FileDescriptor
View Source 
var StreamingStore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpcAgent.StreamingStore",
	HandlerType: (*StreamingStoreServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SetupAppStream",
			Handler:       _StreamingStore_SetupAppStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "agent.proto",
}

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

Functions

func RegisterStreamingStoreServer 

func RegisterStreamingStoreServer(s grpc.ServiceRegistrar, srv StreamingStoreServer)

Types

type AppInfo 

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

func (*AppInfo) Descriptor deprecated 

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

Deprecated: Use AppInfo.ProtoReflect.Descriptor instead.

func (*AppInfo) GetName 

func (x *AppInfo) GetName() string

func (*AppInfo) GetUuid 

func (x *AppInfo) GetUuid() string

func (*AppInfo) ProtoMessage 

func (*AppInfo) ProtoMessage()

func (*AppInfo) ProtoReflect 

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

func (*AppInfo) Reset 

func (x *AppInfo) Reset()

func (*AppInfo) String 

func (x *AppInfo) String() string

type Response 

type Response struct {
	Status  Response_ResponseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=grpcAgent.Response_ResponseStatus" json:"status,omitempty"`
	Message string                  `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Details *structpb.Struct        `protobuf:"bytes,3,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetDetails 

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

func (*Response) GetMessage 

func (x *Response) GetMessage() string

func (*Response) GetStatus 

func (x *Response) GetStatus() Response_ResponseStatus

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type Response_ResponseStatus 

type Response_ResponseStatus int32
const (
	Response_ERROR              Response_ResponseStatus = 0
	Response_SUCCESS            Response_ResponseStatus = 1
	Response_SUCCESS_WITH_ERROR Response_ResponseStatus = 2 //example- notification sent to all but one node
)

func (Response_ResponseStatus) Descriptor 

func (Response_ResponseStatus) Descriptor() protoreflect.EnumDescriptor

func (Response_ResponseStatus) Enum 

func (x Response_ResponseStatus) Enum() *Response_ResponseStatus

func (Response_ResponseStatus) EnumDescriptor deprecated 

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

Deprecated: Use Response_ResponseStatus.Descriptor instead.

func (Response_ResponseStatus) Number 

func (x Response_ResponseStatus) Number() protoreflect.EnumNumber

func (Response_ResponseStatus) String 

func (x Response_ResponseStatus) String() string

func (Response_ResponseStatus) Type 

func (Response_ResponseStatus) Type() protoreflect.EnumType

type StreamResponse 

type StreamResponse struct {
	Type    StreamResponse_ResponseType `protobuf:"varint,1,opt,name=type,proto3,enum=grpcAgent.StreamResponse_ResponseType" json:"type,omitempty"` //identifier to determine the type of message
	Message *structpb.Struct            `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                                       //call details
	// contains filtered or unexported fields
}

func (*StreamResponse) Descriptor deprecated 

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetMessage 

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

func (*StreamResponse) GetType 

func (x *StreamResponse) GetType() StreamResponse_ResponseType

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect 

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

func (*StreamResponse) Reset 

func (x *StreamResponse) Reset()

func (*StreamResponse) String 

func (x *StreamResponse) String() string

type StreamResponse_ResponseType 

type StreamResponse_ResponseType int32
const (
	StreamResponse_JOB_NOTIFICATION_INIT   StreamResponse_ResponseType = 0
	StreamResponse_JOB_NOTIFICATION_START  StreamResponse_ResponseType = 1
	StreamResponse_JOB_NOTIFICATION_RELOAD StreamResponse_ResponseType = 2
)

func (StreamResponse_ResponseType) Descriptor 

func (StreamResponse_ResponseType) Descriptor() protoreflect.EnumDescriptor

func (StreamResponse_ResponseType) Enum 

func (x StreamResponse_ResponseType) Enum() *StreamResponse_ResponseType

func (StreamResponse_ResponseType) EnumDescriptor deprecated 

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

Deprecated: Use StreamResponse_ResponseType.Descriptor instead.

func (StreamResponse_ResponseType) Number 

func (x StreamResponse_ResponseType) Number() protoreflect.EnumNumber

func (StreamResponse_ResponseType) String 

func (x StreamResponse_ResponseType) String() string

func (StreamResponse_ResponseType) Type 

func (StreamResponse_ResponseType) Type() protoreflect.EnumType

type StreamingStoreClient 

type StreamingStoreClient interface {
	SetupAppStream(ctx context.Context, in *AppInfo, opts ...grpc.CallOption) (StreamingStore_SetupAppStreamClient, error)
}

StreamingStoreClient is the client API for StreamingStore service.

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

func NewStreamingStoreClient 

func NewStreamingStoreClient(cc grpc.ClientConnInterface) StreamingStoreClient

type StreamingStoreServer 

type StreamingStoreServer interface {
	SetupAppStream(*AppInfo, StreamingStore_SetupAppStreamServer) error
	// contains filtered or unexported methods
}

StreamingStoreServer is the server API for StreamingStore service. All implementations must embed UnimplementedStreamingStoreServer for forward compatibility

type StreamingStore_SetupAppStreamClient 

type StreamingStore_SetupAppStreamClient interface {
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type StreamingStore_SetupAppStreamServer 

type StreamingStore_SetupAppStreamServer interface {
	Send(*StreamResponse) error
	grpc.ServerStream
}

type UnimplementedStreamingStoreServer 

type UnimplementedStreamingStoreServer struct {
}

UnimplementedStreamingStoreServer must be embedded to have forward compatible implementations.

func (UnimplementedStreamingStoreServer) SetupAppStream 

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

type UnsafeStreamingStoreServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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