Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterClientServiceServer(s grpc.ServiceRegistrar, srv ClientServiceServer)
- type AuthRequestV1
- func (*AuthRequestV1) Descriptor() ([]byte, []int)deprecated
- func (x *AuthRequestV1) GetAssertion() string
- func (x *AuthRequestV1) GetClientLibVersion() string
- func (x *AuthRequestV1) GetClientVersion() string
- func (x *AuthRequestV1) GetClusterUuid() string
- func (*AuthRequestV1) ProtoMessage()
- func (x *AuthRequestV1) ProtoReflect() protoreflect.Message
- func (x *AuthRequestV1) Reset()
- func (x *AuthRequestV1) String() string
- type AuthResponseV1
- type ClientServiceClient
- type ClientServiceServer
- type ServicePollingRequestV1
- func (*ServicePollingRequestV1) Descriptor() ([]byte, []int)deprecated
- func (x *ServicePollingRequestV1) GetLimit() int32
- func (*ServicePollingRequestV1) ProtoMessage()
- func (x *ServicePollingRequestV1) ProtoReflect() protoreflect.Message
- func (x *ServicePollingRequestV1) Reset()
- func (x *ServicePollingRequestV1) String() string
- type ServicePollingResponseV1
- func (*ServicePollingResponseV1) Descriptor() ([]byte, []int)deprecated
- func (x *ServicePollingResponseV1) GetDatas() []*ServicePollingResponseV1_Data
- func (*ServicePollingResponseV1) ProtoMessage()
- func (x *ServicePollingResponseV1) ProtoReflect() protoreflect.Message
- func (x *ServicePollingResponseV1) Reset()
- func (x *ServicePollingResponseV1) String() string
- type ServicePollingResponseV1_Data
- func (*ServicePollingResponseV1_Data) Descriptor() ([]byte, []int)deprecated
- func (x *ServicePollingResponseV1_Data) GetClusterUuid() string
- func (x *ServicePollingResponseV1_Data) GetCreated() *timestamppb.Timestamp
- func (x *ServicePollingResponseV1_Data) GetFlow() string
- func (x *ServicePollingResponseV1_Data) GetInputs() []byte
- func (x *ServicePollingResponseV1_Data) GetName() string
- func (x *ServicePollingResponseV1_Data) GetPartitionDate() *timestamppb.Timestamp
- func (x *ServicePollingResponseV1_Data) GetPriority() int32
- func (x *ServicePollingResponseV1_Data) GetStepMax() int32
- func (x *ServicePollingResponseV1_Data) GetSubscribedChannel() *datatype.NullString
- func (x *ServicePollingResponseV1_Data) GetSummary() *datatype.NullString
- func (x *ServicePollingResponseV1_Data) GetTemplateUuid() string
- func (x *ServicePollingResponseV1_Data) GetUuid() string
- func (*ServicePollingResponseV1_Data) ProtoMessage()
- func (x *ServicePollingResponseV1_Data) ProtoReflect() protoreflect.Message
- func (x *ServicePollingResponseV1_Data) Reset()
- func (x *ServicePollingResponseV1_Data) String() string
- type UnimplementedClientServiceServer
- func (UnimplementedClientServiceServer) AuthV1(context.Context, *AuthRequestV1) (*AuthResponseV1, error)
- func (UnimplementedClientServiceServer) ServicePollingV1(context.Context, *ServicePollingRequestV1) (*ServicePollingResponseV1, error)
- func (UnimplementedClientServiceServer) UpdateServiceStatusV1(context.Context, *UpdateServiceStatusRequestV1) (*UpdateServiceStatusResponseV1, error)
- type UnsafeClientServiceServer
- type UpdateServiceStatusRequestV1
- func (*UpdateServiceStatusRequestV1) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateServiceStatusRequestV1) GetEnded() *timestamppb.Timestamp
- func (x *UpdateServiceStatusRequestV1) GetError() string
- func (x *UpdateServiceStatusRequestV1) GetResult() string
- func (x *UpdateServiceStatusRequestV1) GetSequence() int32
- func (x *UpdateServiceStatusRequestV1) GetStarted() *timestamppb.Timestamp
- func (x *UpdateServiceStatusRequestV1) GetStatus() int32
- func (x *UpdateServiceStatusRequestV1) GetUuid() string
- func (*UpdateServiceStatusRequestV1) ProtoMessage()
- func (x *UpdateServiceStatusRequestV1) ProtoReflect() protoreflect.Message
- func (x *UpdateServiceStatusRequestV1) Reset()
- func (x *UpdateServiceStatusRequestV1) String() string
- type UpdateServiceStatusResponseV1
- func (*UpdateServiceStatusResponseV1) Descriptor() ([]byte, []int)deprecated
- func (*UpdateServiceStatusResponseV1) ProtoMessage()
- func (x *UpdateServiceStatusResponseV1) ProtoReflect() protoreflect.Message
- func (x *UpdateServiceStatusResponseV1) Reset()
- func (x *UpdateServiceStatusResponseV1) String() string
Constants ¶
const ( ClientService_AuthV1_FullMethodName = "/pkg.server.api.client.ClientService/Auth_v1" ClientService_ServicePollingV1_FullMethodName = "/pkg.server.api.client.ClientService/ServicePolling_v1" ClientService_UpdateServiceStatusV1_FullMethodName = "/pkg.server.api.client.ClientService/UpdateServiceStatus_v1" )
Variables ¶
var ClientService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pkg.server.api.client.ClientService", HandlerType: (*ClientServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Auth_v1", Handler: _ClientService_AuthV1_Handler, }, { MethodName: "ServicePolling_v1", Handler: _ClientService_ServicePollingV1_Handler, }, { MethodName: "UpdateServiceStatus_v1", Handler: _ClientService_UpdateServiceStatusV1_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pkg/server/api/client/service.proto", }
ClientService_ServiceDesc is the grpc.ServiceDesc for ClientService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pkg_server_api_client_auth_proto protoreflect.FileDescriptor
var File_pkg_server_api_client_service_polling_proto protoreflect.FileDescriptor
var File_pkg_server_api_client_service_proto protoreflect.FileDescriptor
var File_pkg_server_api_client_update_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterClientServiceServer ¶
func RegisterClientServiceServer(s grpc.ServiceRegistrar, srv ClientServiceServer)
Types ¶
type AuthRequestV1 ¶
type AuthRequestV1 struct { ClusterUuid string `protobuf:"bytes,1,opt,name=clusterUuid,proto3" json:"clusterUuid,omitempty"` Assertion string `protobuf:"bytes,2,opt,name=assertion,proto3" json:"assertion,omitempty"` ClientVersion string `protobuf:"bytes,3,opt,name=clientVersion,proto3" json:"clientVersion,omitempty"` ClientLibVersion string `protobuf:"bytes,4,opt,name=clientLibVersion,proto3" json:"clientLibVersion,omitempty"` // contains filtered or unexported fields }
func (*AuthRequestV1) Descriptor
deprecated
func (*AuthRequestV1) Descriptor() ([]byte, []int)
Deprecated: Use AuthRequestV1.ProtoReflect.Descriptor instead.
func (*AuthRequestV1) GetAssertion ¶
func (x *AuthRequestV1) GetAssertion() string
func (*AuthRequestV1) GetClientLibVersion ¶
func (x *AuthRequestV1) GetClientLibVersion() string
func (*AuthRequestV1) GetClientVersion ¶
func (x *AuthRequestV1) GetClientVersion() string
func (*AuthRequestV1) GetClusterUuid ¶
func (x *AuthRequestV1) GetClusterUuid() string
func (*AuthRequestV1) ProtoMessage ¶
func (*AuthRequestV1) ProtoMessage()
func (*AuthRequestV1) ProtoReflect ¶
func (x *AuthRequestV1) ProtoReflect() protoreflect.Message
func (*AuthRequestV1) Reset ¶
func (x *AuthRequestV1) Reset()
func (*AuthRequestV1) String ¶
func (x *AuthRequestV1) String() string
type AuthResponseV1 ¶
type AuthResponseV1 struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*AuthResponseV1) Descriptor
deprecated
func (*AuthResponseV1) Descriptor() ([]byte, []int)
Deprecated: Use AuthResponseV1.ProtoReflect.Descriptor instead.
func (*AuthResponseV1) GetToken ¶
func (x *AuthResponseV1) GetToken() string
func (*AuthResponseV1) ProtoMessage ¶
func (*AuthResponseV1) ProtoMessage()
func (*AuthResponseV1) ProtoReflect ¶
func (x *AuthResponseV1) ProtoReflect() protoreflect.Message
func (*AuthResponseV1) Reset ¶
func (x *AuthResponseV1) Reset()
func (*AuthResponseV1) String ¶
func (x *AuthResponseV1) String() string
type ClientServiceClient ¶
type ClientServiceClient interface { AuthV1(ctx context.Context, in *AuthRequestV1, opts ...grpc.CallOption) (*AuthResponseV1, error) ServicePollingV1(ctx context.Context, in *ServicePollingRequestV1, opts ...grpc.CallOption) (*ServicePollingResponseV1, error) UpdateServiceStatusV1(ctx context.Context, in *UpdateServiceStatusRequestV1, opts ...grpc.CallOption) (*UpdateServiceStatusResponseV1, error) }
ClientServiceClient is the client API for ClientService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewClientServiceClient ¶
func NewClientServiceClient(cc grpc.ClientConnInterface) ClientServiceClient
type ClientServiceServer ¶
type ClientServiceServer interface { AuthV1(context.Context, *AuthRequestV1) (*AuthResponseV1, error) ServicePollingV1(context.Context, *ServicePollingRequestV1) (*ServicePollingResponseV1, error) UpdateServiceStatusV1(context.Context, *UpdateServiceStatusRequestV1) (*UpdateServiceStatusResponseV1, error) // contains filtered or unexported methods }
ClientServiceServer is the server API for ClientService service. All implementations must embed UnimplementedClientServiceServer for forward compatibility
type ServicePollingRequestV1 ¶
type ServicePollingRequestV1 struct { Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"` // contains filtered or unexported fields }
func (*ServicePollingRequestV1) Descriptor
deprecated
func (*ServicePollingRequestV1) Descriptor() ([]byte, []int)
Deprecated: Use ServicePollingRequestV1.ProtoReflect.Descriptor instead.
func (*ServicePollingRequestV1) GetLimit ¶
func (x *ServicePollingRequestV1) GetLimit() int32
func (*ServicePollingRequestV1) ProtoMessage ¶
func (*ServicePollingRequestV1) ProtoMessage()
func (*ServicePollingRequestV1) ProtoReflect ¶
func (x *ServicePollingRequestV1) ProtoReflect() protoreflect.Message
func (*ServicePollingRequestV1) Reset ¶
func (x *ServicePollingRequestV1) Reset()
func (*ServicePollingRequestV1) String ¶
func (x *ServicePollingRequestV1) String() string
type ServicePollingResponseV1 ¶
type ServicePollingResponseV1 struct { Datas []*ServicePollingResponseV1_Data `protobuf:"bytes,1,rep,name=datas,proto3" json:"datas,omitempty"` // contains filtered or unexported fields }
func (*ServicePollingResponseV1) Descriptor
deprecated
func (*ServicePollingResponseV1) Descriptor() ([]byte, []int)
Deprecated: Use ServicePollingResponseV1.ProtoReflect.Descriptor instead.
func (*ServicePollingResponseV1) GetDatas ¶
func (x *ServicePollingResponseV1) GetDatas() []*ServicePollingResponseV1_Data
func (*ServicePollingResponseV1) ProtoMessage ¶
func (*ServicePollingResponseV1) ProtoMessage()
func (*ServicePollingResponseV1) ProtoReflect ¶
func (x *ServicePollingResponseV1) ProtoReflect() protoreflect.Message
func (*ServicePollingResponseV1) Reset ¶
func (x *ServicePollingResponseV1) Reset()
func (*ServicePollingResponseV1) String ¶
func (x *ServicePollingResponseV1) String() string
type ServicePollingResponseV1_Data ¶
type ServicePollingResponseV1_Data struct { PartitionDate *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=partitionDate,proto3" json:"partitionDate,omitempty"` ClusterUuid string `protobuf:"bytes,2,opt,name=clusterUuid,proto3" json:"clusterUuid,omitempty"` Uuid string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Summary *datatype.NullString `protobuf:"bytes,5,opt,name=summary,proto3" json:"summary,omitempty"` TemplateUuid string `protobuf:"bytes,11,opt,name=templateUuid,proto3" json:"templateUuid,omitempty"` Flow string `protobuf:"bytes,12,opt,name=Flow,proto3" json:"Flow,omitempty"` Inputs []byte `protobuf:"bytes,13,opt,name=inputs,proto3" json:"inputs,omitempty"` StepMax int32 `protobuf:"varint,14,opt,name=stepMax,proto3" json:"stepMax,omitempty"` SubscribedChannel *datatype.NullString `protobuf:"bytes,21,opt,name=subscribedChannel,proto3" json:"subscribedChannel,omitempty"` Priority int32 `protobuf:"varint,22,opt,name=priority,proto3" json:"priority,omitempty"` Created *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"` // contains filtered or unexported fields }
func (*ServicePollingResponseV1_Data) Descriptor
deprecated
func (*ServicePollingResponseV1_Data) Descriptor() ([]byte, []int)
Deprecated: Use ServicePollingResponseV1_Data.ProtoReflect.Descriptor instead.
func (*ServicePollingResponseV1_Data) GetClusterUuid ¶
func (x *ServicePollingResponseV1_Data) GetClusterUuid() string
func (*ServicePollingResponseV1_Data) GetCreated ¶
func (x *ServicePollingResponseV1_Data) GetCreated() *timestamppb.Timestamp
func (*ServicePollingResponseV1_Data) GetFlow ¶
func (x *ServicePollingResponseV1_Data) GetFlow() string
func (*ServicePollingResponseV1_Data) GetInputs ¶
func (x *ServicePollingResponseV1_Data) GetInputs() []byte
func (*ServicePollingResponseV1_Data) GetName ¶
func (x *ServicePollingResponseV1_Data) GetName() string
func (*ServicePollingResponseV1_Data) GetPartitionDate ¶
func (x *ServicePollingResponseV1_Data) GetPartitionDate() *timestamppb.Timestamp
func (*ServicePollingResponseV1_Data) GetPriority ¶
func (x *ServicePollingResponseV1_Data) GetPriority() int32
func (*ServicePollingResponseV1_Data) GetStepMax ¶
func (x *ServicePollingResponseV1_Data) GetStepMax() int32
func (*ServicePollingResponseV1_Data) GetSubscribedChannel ¶
func (x *ServicePollingResponseV1_Data) GetSubscribedChannel() *datatype.NullString
func (*ServicePollingResponseV1_Data) GetSummary ¶
func (x *ServicePollingResponseV1_Data) GetSummary() *datatype.NullString
func (*ServicePollingResponseV1_Data) GetTemplateUuid ¶
func (x *ServicePollingResponseV1_Data) GetTemplateUuid() string
func (*ServicePollingResponseV1_Data) GetUuid ¶
func (x *ServicePollingResponseV1_Data) GetUuid() string
func (*ServicePollingResponseV1_Data) ProtoMessage ¶
func (*ServicePollingResponseV1_Data) ProtoMessage()
func (*ServicePollingResponseV1_Data) ProtoReflect ¶
func (x *ServicePollingResponseV1_Data) ProtoReflect() protoreflect.Message
func (*ServicePollingResponseV1_Data) Reset ¶
func (x *ServicePollingResponseV1_Data) Reset()
func (*ServicePollingResponseV1_Data) String ¶
func (x *ServicePollingResponseV1_Data) String() string
type UnimplementedClientServiceServer ¶
type UnimplementedClientServiceServer struct { }
UnimplementedClientServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedClientServiceServer) AuthV1 ¶
func (UnimplementedClientServiceServer) AuthV1(context.Context, *AuthRequestV1) (*AuthResponseV1, error)
func (UnimplementedClientServiceServer) ServicePollingV1 ¶
func (UnimplementedClientServiceServer) ServicePollingV1(context.Context, *ServicePollingRequestV1) (*ServicePollingResponseV1, error)
func (UnimplementedClientServiceServer) UpdateServiceStatusV1 ¶
func (UnimplementedClientServiceServer) UpdateServiceStatusV1(context.Context, *UpdateServiceStatusRequestV1) (*UpdateServiceStatusResponseV1, error)
type UnsafeClientServiceServer ¶
type UnsafeClientServiceServer interface {
// contains filtered or unexported methods
}
UnsafeClientServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClientServiceServer will result in compilation errors.
type UpdateServiceStatusRequestV1 ¶
type UpdateServiceStatusRequestV1 struct { Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"` Sequence int32 `protobuf:"varint,2,opt,name=sequence,proto3" json:"sequence,omitempty"` Status int32 `protobuf:"varint,3,opt,name=status,proto3" json:"status,omitempty"` Result string `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"` Started *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=started,proto3" json:"started,omitempty"` Ended *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=ended,proto3" json:"ended,omitempty"` Error string `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*UpdateServiceStatusRequestV1) Descriptor
deprecated
func (*UpdateServiceStatusRequestV1) Descriptor() ([]byte, []int)
Deprecated: Use UpdateServiceStatusRequestV1.ProtoReflect.Descriptor instead.
func (*UpdateServiceStatusRequestV1) GetEnded ¶
func (x *UpdateServiceStatusRequestV1) GetEnded() *timestamppb.Timestamp
func (*UpdateServiceStatusRequestV1) GetError ¶
func (x *UpdateServiceStatusRequestV1) GetError() string
func (*UpdateServiceStatusRequestV1) GetResult ¶
func (x *UpdateServiceStatusRequestV1) GetResult() string
func (*UpdateServiceStatusRequestV1) GetSequence ¶
func (x *UpdateServiceStatusRequestV1) GetSequence() int32
func (*UpdateServiceStatusRequestV1) GetStarted ¶
func (x *UpdateServiceStatusRequestV1) GetStarted() *timestamppb.Timestamp
func (*UpdateServiceStatusRequestV1) GetStatus ¶
func (x *UpdateServiceStatusRequestV1) GetStatus() int32
func (*UpdateServiceStatusRequestV1) GetUuid ¶
func (x *UpdateServiceStatusRequestV1) GetUuid() string
func (*UpdateServiceStatusRequestV1) ProtoMessage ¶
func (*UpdateServiceStatusRequestV1) ProtoMessage()
func (*UpdateServiceStatusRequestV1) ProtoReflect ¶
func (x *UpdateServiceStatusRequestV1) ProtoReflect() protoreflect.Message
func (*UpdateServiceStatusRequestV1) Reset ¶
func (x *UpdateServiceStatusRequestV1) Reset()
func (*UpdateServiceStatusRequestV1) String ¶
func (x *UpdateServiceStatusRequestV1) String() string
type UpdateServiceStatusResponseV1 ¶
type UpdateServiceStatusResponseV1 struct {
// contains filtered or unexported fields
}
func (*UpdateServiceStatusResponseV1) Descriptor
deprecated
func (*UpdateServiceStatusResponseV1) Descriptor() ([]byte, []int)
Deprecated: Use UpdateServiceStatusResponseV1.ProtoReflect.Descriptor instead.
func (*UpdateServiceStatusResponseV1) ProtoMessage ¶
func (*UpdateServiceStatusResponseV1) ProtoMessage()
func (*UpdateServiceStatusResponseV1) ProtoReflect ¶
func (x *UpdateServiceStatusResponseV1) ProtoReflect() protoreflect.Message
func (*UpdateServiceStatusResponseV1) Reset ¶
func (x *UpdateServiceStatusResponseV1) Reset()
func (*UpdateServiceStatusResponseV1) String ¶
func (x *UpdateServiceStatusResponseV1) String() string