grpcproto

package
v2.0.0-...-66710c2 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	APIService_Ingest_FullMethodName = "/grpcproto.APIService/Ingest"
)

Variables

View Source 
var (
	ResultStatus_name = map[int32]string{
		0: "Error",
		1: "OK",
		2: "Warning",
		3: "NotFound",
	}
	ResultStatus_value = map[string]int32{
		"Error":    0,
		"OK":       1,
		"Warning":  2,
		"NotFound": 3,
	}
)

Enum value maps for ResultStatus.

View Source 
var APIService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpcproto.APIService",
	HandlerType: (*APIServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ingest",
			Handler:    _APIService_Ingest_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "service.proto",
}

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

View Source 
var File_defaultResponse_proto protoreflect.FileDescriptor
View Source 
var File_ingest_proto protoreflect.FileDescriptor
View Source 
var File_service_proto protoreflect.FileDescriptor

Functions

func RegisterAPIServiceServer 

func RegisterAPIServiceServer(s grpc.ServiceRegistrar, srv APIServiceServer)

Types

type APIServiceClient 

type APIServiceClient interface {
	Ingest(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*DefaultResponse, error)
}

APIServiceClient is the client API for APIService 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 NewAPIServiceClient 

func NewAPIServiceClient(cc grpc.ClientConnInterface) APIServiceClient

type APIServiceServer 

type APIServiceServer interface {
	Ingest(context.Context, *IngestRequest) (*DefaultResponse, error)
	// contains filtered or unexported methods
}

APIServiceServer is the server API for APIService service. All implementations must embed UnimplementedAPIServiceServer for forward compatibility

type DefaultResponse 

type DefaultResponse struct {
	Status  ResultStatus `protobuf:"varint,1,opt,name=status,proto3,enum=grpcproto.ResultStatus" json:"status,omitempty"`
	Message string       `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Data    *anypb.Any   `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*DefaultResponse) Descriptor deprecated 

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

Deprecated: Use DefaultResponse.ProtoReflect.Descriptor instead.

func (*DefaultResponse) GetData 

func (x *DefaultResponse) GetData() *anypb.Any

func (*DefaultResponse) GetMessage 

func (x *DefaultResponse) GetMessage() string

func (*DefaultResponse) GetStatus 

func (x *DefaultResponse) GetStatus() ResultStatus

func (*DefaultResponse) ProtoMessage 

func (*DefaultResponse) ProtoMessage()

func (*DefaultResponse) ProtoReflect 

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

func (*DefaultResponse) Reset 

func (x *DefaultResponse) Reset()

func (*DefaultResponse) String 

func (x *DefaultResponse) String() string

type IngestRequest 

type IngestRequest struct {
	Collection    string  `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	Signature     string  `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	Urn           string  `protobuf:"bytes,3,opt,name=urn,proto3" json:"urn,omitempty"`
	Public        bool    `protobuf:"varint,4,opt,name=public,proto3" json:"public,omitempty"`
	PublicActions *string `protobuf:"bytes,5,opt,name=public_actions,json=publicActions,proto3,oneof" json:"public_actions,omitempty"`
	Parent        *string `protobuf:"bytes,6,opt,name=parent,proto3,oneof" json:"parent,omitempty"`
	Nocopy        *bool   `protobuf:"varint,7,opt,name=nocopy,proto3,oneof" json:"nocopy,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestRequest) Descriptor deprecated 

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

Deprecated: Use IngestRequest.ProtoReflect.Descriptor instead.

func (*IngestRequest) GetCollection 

func (x *IngestRequest) GetCollection() string

func (*IngestRequest) GetNocopy 

func (x *IngestRequest) GetNocopy() bool

func (*IngestRequest) GetParent 

func (x *IngestRequest) GetParent() string

func (*IngestRequest) GetPublic 

func (x *IngestRequest) GetPublic() bool

func (*IngestRequest) GetPublicActions 

func (x *IngestRequest) GetPublicActions() string

func (*IngestRequest) GetSignature 

func (x *IngestRequest) GetSignature() string

func (*IngestRequest) GetUrn 

func (x *IngestRequest) GetUrn() string

func (*IngestRequest) ProtoMessage 

func (*IngestRequest) ProtoMessage()

func (*IngestRequest) ProtoReflect 

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

func (*IngestRequest) Reset 

func (x *IngestRequest) Reset()

func (*IngestRequest) String 

func (x *IngestRequest) String() string

type ResultStatus 

type ResultStatus int32
const (
	ResultStatus_Error    ResultStatus = 0
	ResultStatus_OK       ResultStatus = 1
	ResultStatus_Warning  ResultStatus = 2
	ResultStatus_NotFound ResultStatus = 3
)

func (ResultStatus) Descriptor 

func (ResultStatus) Descriptor() protoreflect.EnumDescriptor

func (ResultStatus) Enum 

func (x ResultStatus) Enum() *ResultStatus

func (ResultStatus) EnumDescriptor deprecated 

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

Deprecated: Use ResultStatus.Descriptor instead.

func (ResultStatus) Number 

func (x ResultStatus) Number() protoreflect.EnumNumber

func (ResultStatus) String 

func (x ResultStatus) String() string

func (ResultStatus) Type 

func (ResultStatus) Type() protoreflect.EnumType

type UnimplementedAPIServiceServer 

type UnimplementedAPIServiceServer struct {
}

UnimplementedAPIServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAPIServiceServer) Ingest 

func (UnimplementedAPIServiceServer) Ingest(context.Context, *IngestRequest) (*DefaultResponse, error)

type UnsafeAPIServiceServer 

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

UnsafeAPIServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to APIServiceServer 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.