packet

package
v0.0.0-...-c2c3684 Latest Latest
Warning

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

Go to latest
Published: Jan 10, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var AccountService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "packet.AccountService",
	HandlerType: (*AccountServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateAccount",
			Handler:    _AccountService_CreateAccount_Handler,
		},
		{
			MethodName: "GetAccount",
			Handler:    _AccountService_GetAccount_Handler,
		},
		{
			MethodName: "ProduceAmount",
			Handler:    _AccountService_ProduceAmount_Handler,
		},
		{
			MethodName: "ConsumeAmount",
			Handler:    _AccountService_ConsumeAmount_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "packet.proto",
}

AccountService_ServiceDesc is the grpc.ServiceDesc for AccountService 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_packet_proto protoreflect.FileDescriptor
View Source
var PingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "packet.PingService",
	HandlerType: (*PingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Ping",
			Handler:    _PingService_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "packet.proto",
}

PingService_ServiceDesc is the grpc.ServiceDesc for PingService 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 PointService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "packet.PointService",
	HandlerType: (*PointServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ProducePoint",
			Handler:    _PointService_ProducePoint_Handler,
		},
		{
			MethodName: "ConsumePoint",
			Handler:    _PointService_ConsumePoint_Handler,
		},
		{
			MethodName: "GetPoint",
			Handler:    _PointService_GetPoint_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "packet.proto",
}

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

Functions

func RegisterAccountServiceServer

func RegisterAccountServiceServer(s grpc.ServiceRegistrar, srv AccountServiceServer)

func RegisterPingServiceServer

func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer)

func RegisterPointServiceServer

func RegisterPointServiceServer(s grpc.ServiceRegistrar, srv PointServiceServer)

Types

type Account

type Account struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Owner     string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Email     string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	Amount    int64  `protobuf:"varint,4,opt,name=amount,proto3" json:"amount,omitempty"`
	CreatedAt string `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt string `protobuf:"bytes,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Account) Descriptor deprecated

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

Deprecated: Use Account.ProtoReflect.Descriptor instead.

func (*Account) GetAmount

func (x *Account) GetAmount() int64

func (*Account) GetCreatedAt

func (x *Account) GetCreatedAt() string

func (*Account) GetEmail

func (x *Account) GetEmail() string

func (*Account) GetId

func (x *Account) GetId() string

func (*Account) GetOwner

func (x *Account) GetOwner() string

func (*Account) GetUpdatedAt

func (x *Account) GetUpdatedAt() string

func (*Account) ProtoMessage

func (*Account) ProtoMessage()

func (*Account) ProtoReflect

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

func (*Account) Reset

func (x *Account) Reset()

func (*Account) String

func (x *Account) String() string

type AccountServiceClient

type AccountServiceClient interface {
	CreateAccount(ctx context.Context, in *CreateAccountRequest, opts ...grpc.CallOption) (*CreateAccountResponse, error)
	GetAccount(ctx context.Context, in *GetAccountRequest, opts ...grpc.CallOption) (*GetAccountResponse, error)
	ProduceAmount(ctx context.Context, in *ProduceAmountRequest, opts ...grpc.CallOption) (*ProduceAmountResponse, error)
	ConsumeAmount(ctx context.Context, in *ConsumeAmountRequest, opts ...grpc.CallOption) (*ConsumeAmountResponse, error)
}

AccountServiceClient is the client API for AccountService 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.

type AccountServiceServer

AccountServiceServer is the server API for AccountService service. All implementations should embed UnimplementedAccountServiceServer for forward compatibility

type ConsumeAmountRequest

type ConsumeAmountRequest struct {
	Owner  string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Amount int64  `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeAmountRequest) Descriptor deprecated

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

Deprecated: Use ConsumeAmountRequest.ProtoReflect.Descriptor instead.

func (*ConsumeAmountRequest) GetAmount

func (x *ConsumeAmountRequest) GetAmount() int64

func (*ConsumeAmountRequest) GetOwner

func (x *ConsumeAmountRequest) GetOwner() string

func (*ConsumeAmountRequest) ProtoMessage

func (*ConsumeAmountRequest) ProtoMessage()

func (*ConsumeAmountRequest) ProtoReflect

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

func (*ConsumeAmountRequest) Reset

func (x *ConsumeAmountRequest) Reset()

func (*ConsumeAmountRequest) String

func (x *ConsumeAmountRequest) String() string

type ConsumeAmountResponse

type ConsumeAmountResponse struct {
	Amount int64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeAmountResponse) Descriptor deprecated

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

Deprecated: Use ConsumeAmountResponse.ProtoReflect.Descriptor instead.

func (*ConsumeAmountResponse) GetAmount

func (x *ConsumeAmountResponse) GetAmount() int64

func (*ConsumeAmountResponse) ProtoMessage

func (*ConsumeAmountResponse) ProtoMessage()

func (*ConsumeAmountResponse) ProtoReflect

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

func (*ConsumeAmountResponse) Reset

func (x *ConsumeAmountResponse) Reset()

func (*ConsumeAmountResponse) String

func (x *ConsumeAmountResponse) String() string

type ConsumePointRequest

type ConsumePointRequest struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Point int64  `protobuf:"varint,2,opt,name=point,proto3" json:"point,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumePointRequest) Descriptor deprecated

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

Deprecated: Use ConsumePointRequest.ProtoReflect.Descriptor instead.

func (*ConsumePointRequest) GetOwner

func (x *ConsumePointRequest) GetOwner() string

func (*ConsumePointRequest) GetPoint

func (x *ConsumePointRequest) GetPoint() int64

func (*ConsumePointRequest) ProtoMessage

func (*ConsumePointRequest) ProtoMessage()

func (*ConsumePointRequest) ProtoReflect

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

func (*ConsumePointRequest) Reset

func (x *ConsumePointRequest) Reset()

func (*ConsumePointRequest) String

func (x *ConsumePointRequest) String() string

type ConsumePointResponse

type ConsumePointResponse struct {
	Point int64 `protobuf:"varint,1,opt,name=point,proto3" json:"point,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumePointResponse) Descriptor deprecated

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

Deprecated: Use ConsumePointResponse.ProtoReflect.Descriptor instead.

func (*ConsumePointResponse) GetPoint

func (x *ConsumePointResponse) GetPoint() int64

func (*ConsumePointResponse) ProtoMessage

func (*ConsumePointResponse) ProtoMessage()

func (*ConsumePointResponse) ProtoReflect

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

func (*ConsumePointResponse) Reset

func (x *ConsumePointResponse) Reset()

func (*ConsumePointResponse) String

func (x *ConsumePointResponse) String() string

type CreateAccountRequest

type CreateAccountRequest struct {
	Email string `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateAccountRequest) Descriptor deprecated

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

Deprecated: Use CreateAccountRequest.ProtoReflect.Descriptor instead.

func (*CreateAccountRequest) GetEmail

func (x *CreateAccountRequest) GetEmail() string

func (*CreateAccountRequest) ProtoMessage

func (*CreateAccountRequest) ProtoMessage()

func (*CreateAccountRequest) ProtoReflect

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

func (*CreateAccountRequest) Reset

func (x *CreateAccountRequest) Reset()

func (*CreateAccountRequest) String

func (x *CreateAccountRequest) String() string

type CreateAccountResponse

type CreateAccountResponse struct {
	Data *Account `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateAccountResponse) Descriptor deprecated

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

Deprecated: Use CreateAccountResponse.ProtoReflect.Descriptor instead.

func (*CreateAccountResponse) GetData

func (x *CreateAccountResponse) GetData() *Account

func (*CreateAccountResponse) ProtoMessage

func (*CreateAccountResponse) ProtoMessage()

func (*CreateAccountResponse) ProtoReflect

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

func (*CreateAccountResponse) Reset

func (x *CreateAccountResponse) Reset()

func (*CreateAccountResponse) String

func (x *CreateAccountResponse) String() string

type GetAccountRequest

type GetAccountRequest struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAccountRequest) Descriptor deprecated

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

Deprecated: Use GetAccountRequest.ProtoReflect.Descriptor instead.

func (*GetAccountRequest) GetOwner

func (x *GetAccountRequest) GetOwner() string

func (*GetAccountRequest) ProtoMessage

func (*GetAccountRequest) ProtoMessage()

func (*GetAccountRequest) ProtoReflect

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

func (*GetAccountRequest) Reset

func (x *GetAccountRequest) Reset()

func (*GetAccountRequest) String

func (x *GetAccountRequest) String() string

type GetAccountResponse

type GetAccountResponse struct {
	Data *Account `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAccountResponse) Descriptor deprecated

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

Deprecated: Use GetAccountResponse.ProtoReflect.Descriptor instead.

func (*GetAccountResponse) GetData

func (x *GetAccountResponse) GetData() *Account

func (*GetAccountResponse) ProtoMessage

func (*GetAccountResponse) ProtoMessage()

func (*GetAccountResponse) ProtoReflect

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

func (*GetAccountResponse) Reset

func (x *GetAccountResponse) Reset()

func (*GetAccountResponse) String

func (x *GetAccountResponse) String() string

type GetPointRequest

type GetPointRequest struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPointRequest) Descriptor deprecated

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

Deprecated: Use GetPointRequest.ProtoReflect.Descriptor instead.

func (*GetPointRequest) GetOwner

func (x *GetPointRequest) GetOwner() string

func (*GetPointRequest) ProtoMessage

func (*GetPointRequest) ProtoMessage()

func (*GetPointRequest) ProtoReflect

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

func (*GetPointRequest) Reset

func (x *GetPointRequest) Reset()

func (*GetPointRequest) String

func (x *GetPointRequest) String() string

type GetPointResponse

type GetPointResponse struct {
	Point int64 `protobuf:"varint,1,opt,name=point,proto3" json:"point,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPointResponse) Descriptor deprecated

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

Deprecated: Use GetPointResponse.ProtoReflect.Descriptor instead.

func (*GetPointResponse) GetPoint

func (x *GetPointResponse) GetPoint() int64

func (*GetPointResponse) ProtoMessage

func (*GetPointResponse) ProtoMessage()

func (*GetPointResponse) ProtoReflect

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

func (*GetPointResponse) Reset

func (x *GetPointResponse) Reset()

func (*GetPointResponse) String

func (x *GetPointResponse) String() string

type PingResponse

type PingResponse struct {
	Ts int64 `protobuf:"varint,1,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetTs

func (x *PingResponse) GetTs() int64

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect

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

func (*PingResponse) Reset

func (x *PingResponse) Reset()

func (*PingResponse) String

func (x *PingResponse) String() string

type PingServiceClient

type PingServiceClient interface {
	Ping(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*PingResponse, error)
}

PingServiceClient is the client API for PingService 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.

type PingServiceServer

type PingServiceServer interface {
	Ping(context.Context, *emptypb.Empty) (*PingResponse, error)
}

PingServiceServer is the server API for PingService service. All implementations should embed UnimplementedPingServiceServer for forward compatibility

type PointServiceClient

type PointServiceClient interface {
	ProducePoint(ctx context.Context, in *ProducePointRequest, opts ...grpc.CallOption) (*ProducePointResponse, error)
	ConsumePoint(ctx context.Context, in *ConsumePointRequest, opts ...grpc.CallOption) (*ConsumePointResponse, error)
	GetPoint(ctx context.Context, in *GetPointRequest, opts ...grpc.CallOption) (*GetPointResponse, error)
}

PointServiceClient is the client API for PointService 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.

type PointServiceServer

PointServiceServer is the server API for PointService service. All implementations should embed UnimplementedPointServiceServer for forward compatibility

type ProduceAmountRequest

type ProduceAmountRequest struct {
	Owner  string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Amount int64  `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*ProduceAmountRequest) Descriptor deprecated

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

Deprecated: Use ProduceAmountRequest.ProtoReflect.Descriptor instead.

func (*ProduceAmountRequest) GetAmount

func (x *ProduceAmountRequest) GetAmount() int64

func (*ProduceAmountRequest) GetOwner

func (x *ProduceAmountRequest) GetOwner() string

func (*ProduceAmountRequest) ProtoMessage

func (*ProduceAmountRequest) ProtoMessage()

func (*ProduceAmountRequest) ProtoReflect

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

func (*ProduceAmountRequest) Reset

func (x *ProduceAmountRequest) Reset()

func (*ProduceAmountRequest) String

func (x *ProduceAmountRequest) String() string

type ProduceAmountResponse

type ProduceAmountResponse struct {
	Amount int64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*ProduceAmountResponse) Descriptor deprecated

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

Deprecated: Use ProduceAmountResponse.ProtoReflect.Descriptor instead.

func (*ProduceAmountResponse) GetAmount

func (x *ProduceAmountResponse) GetAmount() int64

func (*ProduceAmountResponse) ProtoMessage

func (*ProduceAmountResponse) ProtoMessage()

func (*ProduceAmountResponse) ProtoReflect

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

func (*ProduceAmountResponse) Reset

func (x *ProduceAmountResponse) Reset()

func (*ProduceAmountResponse) String

func (x *ProduceAmountResponse) String() string

type ProducePointRequest

type ProducePointRequest struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Point int64  `protobuf:"varint,2,opt,name=point,proto3" json:"point,omitempty"`
	// contains filtered or unexported fields
}

func (*ProducePointRequest) Descriptor deprecated

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

Deprecated: Use ProducePointRequest.ProtoReflect.Descriptor instead.

func (*ProducePointRequest) GetOwner

func (x *ProducePointRequest) GetOwner() string

func (*ProducePointRequest) GetPoint

func (x *ProducePointRequest) GetPoint() int64

func (*ProducePointRequest) ProtoMessage

func (*ProducePointRequest) ProtoMessage()

func (*ProducePointRequest) ProtoReflect

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

func (*ProducePointRequest) Reset

func (x *ProducePointRequest) Reset()

func (*ProducePointRequest) String

func (x *ProducePointRequest) String() string

type ProducePointResponse

type ProducePointResponse struct {
	Point int64 `protobuf:"varint,1,opt,name=point,proto3" json:"point,omitempty"`
	// contains filtered or unexported fields
}

func (*ProducePointResponse) Descriptor deprecated

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

Deprecated: Use ProducePointResponse.ProtoReflect.Descriptor instead.

func (*ProducePointResponse) GetPoint

func (x *ProducePointResponse) GetPoint() int64

func (*ProducePointResponse) ProtoMessage

func (*ProducePointResponse) ProtoMessage()

func (*ProducePointResponse) ProtoReflect

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

func (*ProducePointResponse) Reset

func (x *ProducePointResponse) Reset()

func (*ProducePointResponse) String

func (x *ProducePointResponse) String() string

type UnimplementedAccountServiceServer

type UnimplementedAccountServiceServer struct {
}

UnimplementedAccountServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAccountServiceServer) ConsumeAmount

func (UnimplementedAccountServiceServer) CreateAccount

func (UnimplementedAccountServiceServer) GetAccount

func (UnimplementedAccountServiceServer) ProduceAmount

type UnimplementedPingServiceServer

type UnimplementedPingServiceServer struct {
}

UnimplementedPingServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedPingServiceServer) Ping

type UnimplementedPointServiceServer

type UnimplementedPointServiceServer struct {
}

UnimplementedPointServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedPointServiceServer) ConsumePoint

func (UnimplementedPointServiceServer) GetPoint

func (UnimplementedPointServiceServer) ProducePoint

type UnsafeAccountServiceServer

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

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

type UnsafePingServiceServer

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

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

type UnsafePointServiceServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL