synctestproto

package
v0.5.0-alpha.7 Latest Latest
Warning

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

 Go to latest Published: Jul 31, 2024 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSynctest        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSynctest          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSynctest = fmt.Errorf("proto: unexpected end of group")
)

Functions

func DRPCRegisterCounterSync 

func DRPCRegisterCounterSync(mux drpc.Mux, impl DRPCCounterSyncServer) error

Types

type CounterIncrease 

type CounterIncrease struct {
	Value    int32  `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	ObjectId string `protobuf:"bytes,2,opt,name=objectId,proto3" json:"objectId,omitempty"`
}

func (*CounterIncrease) Descriptor 

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

func (*CounterIncrease) GetObjectId 

func (m *CounterIncrease) GetObjectId() string

func (*CounterIncrease) GetValue 

func (m *CounterIncrease) GetValue() int32

func (*CounterIncrease) Marshal 

func (m *CounterIncrease) Marshal() (dAtA []byte, err error)

func (*CounterIncrease) MarshalTo 

func (m *CounterIncrease) MarshalTo(dAtA []byte) (int, error)

func (*CounterIncrease) MarshalToSizedBuffer 

func (m *CounterIncrease) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CounterIncrease) MsgSize 

func (c *CounterIncrease) MsgSize() uint64

func (*CounterIncrease) ProtoMessage 

func (*CounterIncrease) ProtoMessage()

func (*CounterIncrease) Reset 

func (m *CounterIncrease) Reset()

func (*CounterIncrease) Size 

func (m *CounterIncrease) Size() (n int)

func (*CounterIncrease) String 

func (m *CounterIncrease) String() string

func (*CounterIncrease) Unmarshal 

func (m *CounterIncrease) Unmarshal(dAtA []byte) error

func (*CounterIncrease) XXX_DiscardUnknown 

func (m *CounterIncrease) XXX_DiscardUnknown()

func (*CounterIncrease) XXX_Marshal 

func (m *CounterIncrease) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CounterIncrease) XXX_MarshalAppend 

func (m *CounterIncrease) XXX_MarshalAppend(b []byte, newLen int) ([]byte, error)

func (*CounterIncrease) XXX_Merge 

func (m *CounterIncrease) XXX_Merge(src proto.Message)

func (*CounterIncrease) XXX_Size 

func (m *CounterIncrease) XXX_Size() int

func (*CounterIncrease) XXX_Unmarshal 

func (m *CounterIncrease) XXX_Unmarshal(b []byte) error

type CounterRequest 

type CounterRequest struct {
	ExistingValues []int32 `protobuf:"varint,1,rep,packed,name=existingValues,proto3" json:"existingValues,omitempty"`
	ObjectId       string  `protobuf:"bytes,2,opt,name=objectId,proto3" json:"objectId,omitempty"`
}

func (*CounterRequest) Descriptor 

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

func (*CounterRequest) GetExistingValues 

func (m *CounterRequest) GetExistingValues() []int32

func (*CounterRequest) GetObjectId 

func (m *CounterRequest) GetObjectId() string

func (*CounterRequest) Marshal 

func (m *CounterRequest) Marshal() (dAtA []byte, err error)

func (*CounterRequest) MarshalTo 

func (m *CounterRequest) MarshalTo(dAtA []byte) (int, error)

func (*CounterRequest) MarshalToSizedBuffer 

func (m *CounterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CounterRequest) ProtoMessage 

func (*CounterRequest) ProtoMessage()

func (*CounterRequest) Reset 

func (m *CounterRequest) Reset()

func (*CounterRequest) Size 

func (m *CounterRequest) Size() (n int)

func (*CounterRequest) String 

func (m *CounterRequest) String() string

func (*CounterRequest) Unmarshal 

func (m *CounterRequest) Unmarshal(dAtA []byte) error

func (*CounterRequest) XXX_DiscardUnknown 

func (m *CounterRequest) XXX_DiscardUnknown()

func (*CounterRequest) XXX_Marshal 

func (m *CounterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CounterRequest) XXX_MarshalAppend 

func (m *CounterRequest) XXX_MarshalAppend(b []byte, newLen int) ([]byte, error)

func (*CounterRequest) XXX_Merge 

func (m *CounterRequest) XXX_Merge(src proto.Message)

func (*CounterRequest) XXX_Size 

func (m *CounterRequest) XXX_Size() int

func (*CounterRequest) XXX_Unmarshal 

func (m *CounterRequest) XXX_Unmarshal(b []byte) error

type DRPCCounterSyncClient 

type DRPCCounterSyncClient interface {
	DRPCConn() drpc.Conn

	CounterStreamRequest(ctx context.Context, in *CounterRequest) (DRPCCounterSync_CounterStreamRequestClient, error)
	CounterStream(ctx context.Context) (DRPCCounterSync_CounterStreamClient, error)
}

func NewDRPCCounterSyncClient 

func NewDRPCCounterSyncClient(cc drpc.Conn) DRPCCounterSyncClient

type DRPCCounterSyncDescription 

type DRPCCounterSyncDescription struct{}

func (DRPCCounterSyncDescription) Method 

func (DRPCCounterSyncDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCCounterSyncDescription) NumMethods 

func (DRPCCounterSyncDescription) NumMethods() int

type DRPCCounterSyncServer 

type DRPCCounterSyncServer interface {
	CounterStreamRequest(*CounterRequest, DRPCCounterSync_CounterStreamRequestStream) error
	CounterStream(DRPCCounterSync_CounterStreamStream) error
}

type DRPCCounterSyncUnimplementedServer 

type DRPCCounterSyncUnimplementedServer struct{}

func (*DRPCCounterSyncUnimplementedServer) CounterStream 

func (s *DRPCCounterSyncUnimplementedServer) CounterStream(DRPCCounterSync_CounterStreamStream) error

func (*DRPCCounterSyncUnimplementedServer) CounterStreamRequest 

func (s *DRPCCounterSyncUnimplementedServer) CounterStreamRequest(*CounterRequest, DRPCCounterSync_CounterStreamRequestStream) error

type DRPCCounterSync_CounterStreamClient 

type DRPCCounterSync_CounterStreamClient interface {
	drpc.Stream
	Send(*CounterIncrease) error
	Recv() (*CounterIncrease, error)
}

type DRPCCounterSync_CounterStreamRequestClient 

type DRPCCounterSync_CounterStreamRequestClient interface {
	drpc.Stream
	Recv() (*CounterIncrease, error)
}

type DRPCCounterSync_CounterStreamRequestStream 

type DRPCCounterSync_CounterStreamRequestStream interface {
	drpc.Stream
	Send(*CounterIncrease) error
}

type DRPCCounterSync_CounterStreamStream 

type DRPCCounterSync_CounterStreamStream interface {
	drpc.Stream
	Send(*CounterIncrease) error
	Recv() (*CounterIncrease, error)
}

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.