messages

package
v0.0.0-...-4ba8117 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessages        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessages          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessages = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var StatusResponse_StateType_name = map[int32]string{
	0: "STARTED",
	1: "STOPPED",
	2: "UNKNOWN",
}
View Source 
var StatusResponse_StateType_value = map[string]int32{
	"STARTED": 0,
	"STOPPED": 1,
	"UNKNOWN": 2,
}

Functions

This section is empty.

Types

type AddressCounterRequest 

type AddressCounterRequest struct {
	Sender string `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

func (*AddressCounterRequest) Descriptor 

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

func (*AddressCounterRequest) Equal 

func (this *AddressCounterRequest) Equal(that interface{}) bool

func (*AddressCounterRequest) GetSender 

func (m *AddressCounterRequest) GetSender() string

func (*AddressCounterRequest) GoString 

func (this *AddressCounterRequest) GoString() string

func (*AddressCounterRequest) Marshal 

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

func (*AddressCounterRequest) MarshalTo 

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

func (*AddressCounterRequest) MarshalToSizedBuffer 

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

func (*AddressCounterRequest) ProtoMessage 

func (*AddressCounterRequest) ProtoMessage()

func (*AddressCounterRequest) Reset 

func (m *AddressCounterRequest) Reset()

func (*AddressCounterRequest) Size 

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

func (*AddressCounterRequest) String 

func (this *AddressCounterRequest) String() string

func (*AddressCounterRequest) Unmarshal 

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

func (*AddressCounterRequest) XXX_DiscardUnknown 

func (m *AddressCounterRequest) XXX_DiscardUnknown()

func (*AddressCounterRequest) XXX_Marshal 

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

func (*AddressCounterRequest) XXX_Merge 

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

func (*AddressCounterRequest) XXX_Size 

func (m *AddressCounterRequest) XXX_Size() int

func (*AddressCounterRequest) XXX_Unmarshal 

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

type AddressCounterResponse 

type AddressCounterResponse struct {
	ID   string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=Addr,proto3" json:"Addr,omitempty"`
}

func (*AddressCounterResponse) Descriptor 

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

func (*AddressCounterResponse) Equal 

func (this *AddressCounterResponse) Equal(that interface{}) bool

func (*AddressCounterResponse) GetAddr 

func (m *AddressCounterResponse) GetAddr() string

func (*AddressCounterResponse) GetID 

func (m *AddressCounterResponse) GetID() string

func (*AddressCounterResponse) GoString 

func (this *AddressCounterResponse) GoString() string

func (*AddressCounterResponse) Marshal 

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

func (*AddressCounterResponse) MarshalTo 

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

func (*AddressCounterResponse) MarshalToSizedBuffer 

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

func (*AddressCounterResponse) ProtoMessage 

func (*AddressCounterResponse) ProtoMessage()

func (*AddressCounterResponse) Reset 

func (m *AddressCounterResponse) Reset()

func (*AddressCounterResponse) Size 

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

func (*AddressCounterResponse) String 

func (this *AddressCounterResponse) String() string

func (*AddressCounterResponse) Unmarshal 

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

func (*AddressCounterResponse) XXX_DiscardUnknown 

func (m *AddressCounterResponse) XXX_DiscardUnknown()

func (*AddressCounterResponse) XXX_Marshal 

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

func (*AddressCounterResponse) XXX_Merge 

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

func (*AddressCounterResponse) XXX_Size 

func (m *AddressCounterResponse) XXX_Size() int

func (*AddressCounterResponse) XXX_Unmarshal 

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

type InfoCounterRequest 

type InfoCounterRequest struct {
	Sender string `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

func (*InfoCounterRequest) Descriptor 

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

func (*InfoCounterRequest) Equal 

func (this *InfoCounterRequest) Equal(that interface{}) bool

func (*InfoCounterRequest) GetSender 

func (m *InfoCounterRequest) GetSender() string

func (*InfoCounterRequest) GoString 

func (this *InfoCounterRequest) GoString() string

func (*InfoCounterRequest) Marshal 

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

func (*InfoCounterRequest) MarshalTo 

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

func (*InfoCounterRequest) MarshalToSizedBuffer 

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

func (*InfoCounterRequest) ProtoMessage 

func (*InfoCounterRequest) ProtoMessage()

func (*InfoCounterRequest) Reset 

func (m *InfoCounterRequest) Reset()

func (*InfoCounterRequest) Size 

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

func (*InfoCounterRequest) String 

func (this *InfoCounterRequest) String() string

func (*InfoCounterRequest) Unmarshal 

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

func (*InfoCounterRequest) XXX_DiscardUnknown 

func (m *InfoCounterRequest) XXX_DiscardUnknown()

func (*InfoCounterRequest) XXX_Marshal 

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

func (*InfoCounterRequest) XXX_Merge 

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

func (*InfoCounterRequest) XXX_Size 

func (m *InfoCounterRequest) XXX_Size() int

func (*InfoCounterRequest) XXX_Unmarshal 

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

type InfoCounterResponse 

type InfoCounterResponse struct {
	Inputs  int64 `protobuf:"varint,1,opt,name=Inputs,proto3" json:"Inputs,omitempty"`
	Outputs int64 `protobuf:"varint,2,opt,name=Outputs,proto3" json:"Outputs,omitempty"`
}

func (*InfoCounterResponse) Descriptor 

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

func (*InfoCounterResponse) Equal 

func (this *InfoCounterResponse) Equal(that interface{}) bool

func (*InfoCounterResponse) GetInputs 

func (m *InfoCounterResponse) GetInputs() int64

func (*InfoCounterResponse) GetOutputs 

func (m *InfoCounterResponse) GetOutputs() int64

func (*InfoCounterResponse) GoString 

func (this *InfoCounterResponse) GoString() string

func (*InfoCounterResponse) Marshal 

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

func (*InfoCounterResponse) MarshalTo 

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

func (*InfoCounterResponse) MarshalToSizedBuffer 

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

func (*InfoCounterResponse) ProtoMessage 

func (*InfoCounterResponse) ProtoMessage()

func (*InfoCounterResponse) Reset 

func (m *InfoCounterResponse) Reset()

func (*InfoCounterResponse) Size 

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

func (*InfoCounterResponse) String 

func (this *InfoCounterResponse) String() string

func (*InfoCounterResponse) Unmarshal 

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

func (*InfoCounterResponse) XXX_DiscardUnknown 

func (m *InfoCounterResponse) XXX_DiscardUnknown()

func (*InfoCounterResponse) XXX_Marshal 

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

func (*InfoCounterResponse) XXX_Merge 

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

func (*InfoCounterResponse) XXX_Size 

func (m *InfoCounterResponse) XXX_Size() int

func (*InfoCounterResponse) XXX_Unmarshal 

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

type Restart 

type Restart struct {
}

func (*Restart) Descriptor 

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

func (*Restart) Equal 

func (this *Restart) Equal(that interface{}) bool

func (*Restart) GoString 

func (this *Restart) GoString() string

func (*Restart) Marshal 

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

func (*Restart) MarshalTo 

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

func (*Restart) MarshalToSizedBuffer 

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

func (*Restart) ProtoMessage 

func (*Restart) ProtoMessage()

func (*Restart) Reset 

func (m *Restart) Reset()

func (*Restart) Size 

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

func (*Restart) String 

func (this *Restart) String() string

func (*Restart) Unmarshal 

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

func (*Restart) XXX_DiscardUnknown 

func (m *Restart) XXX_DiscardUnknown()

func (*Restart) XXX_Marshal 

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

func (*Restart) XXX_Merge 

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

func (*Restart) XXX_Size 

func (m *Restart) XXX_Size() int

func (*Restart) XXX_Unmarshal 

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

type Start 

type Start struct {
}

func (*Start) Descriptor 

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

func (*Start) Equal 

func (this *Start) Equal(that interface{}) bool

func (*Start) GoString 

func (this *Start) GoString() string

func (*Start) Marshal 

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

func (*Start) MarshalTo 

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

func (*Start) MarshalToSizedBuffer 

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

func (*Start) ProtoMessage 

func (*Start) ProtoMessage()

func (*Start) Reset 

func (m *Start) Reset()

func (*Start) Size 

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

func (*Start) String 

func (this *Start) String() string

func (*Start) Unmarshal 

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

func (*Start) XXX_DiscardUnknown 

func (m *Start) XXX_DiscardUnknown()

func (*Start) XXX_Marshal 

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

func (*Start) XXX_Merge 

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

func (*Start) XXX_Size 

func (m *Start) XXX_Size() int

func (*Start) XXX_Unmarshal 

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

type StatusRequest 

type StatusRequest struct {
	Sender string `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) Equal 

func (this *StatusRequest) Equal(that interface{}) bool

func (*StatusRequest) GetSender 

func (m *StatusRequest) GetSender() string

func (*StatusRequest) GoString 

func (this *StatusRequest) GoString() string

func (*StatusRequest) Marshal 

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

func (*StatusRequest) MarshalTo 

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

func (*StatusRequest) MarshalToSizedBuffer 

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

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) Size 

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

func (*StatusRequest) String 

func (this *StatusRequest) String() string

func (*StatusRequest) Unmarshal 

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

func (*StatusRequest) XXX_DiscardUnknown 

func (m *StatusRequest) XXX_DiscardUnknown()

func (*StatusRequest) XXX_Marshal 

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

func (*StatusRequest) XXX_Merge 

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

func (*StatusRequest) XXX_Size 

func (m *StatusRequest) XXX_Size() int

func (*StatusRequest) XXX_Unmarshal 

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

type StatusResponse 

type StatusResponse struct {
	State StatusResponse_StateType `protobuf:"varint,1,opt,name=State,proto3,enum=messages.StatusResponse_StateType" json:"State,omitempty"`
}

func (*StatusResponse) Descriptor 

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

func (*StatusResponse) Equal 

func (this *StatusResponse) Equal(that interface{}) bool

func (*StatusResponse) GetState 

func (m *StatusResponse) GetState() StatusResponse_StateType

func (*StatusResponse) GoString 

func (this *StatusResponse) GoString() string

func (*StatusResponse) Marshal 

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

func (*StatusResponse) MarshalTo 

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

func (*StatusResponse) MarshalToSizedBuffer 

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

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) Reset 

func (m *StatusResponse) Reset()

func (*StatusResponse) Size 

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

func (*StatusResponse) String 

func (this *StatusResponse) String() string

func (*StatusResponse) Unmarshal 

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

func (*StatusResponse) XXX_DiscardUnknown 

func (m *StatusResponse) XXX_DiscardUnknown()

func (*StatusResponse) XXX_Marshal 

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

func (*StatusResponse) XXX_Merge 

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

func (*StatusResponse) XXX_Size 

func (m *StatusResponse) XXX_Size() int

func (*StatusResponse) XXX_Unmarshal 

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

type StatusResponse_StateType 

type StatusResponse_StateType int32
const (
	STARTED StatusResponse_StateType = 0
	STOPPED StatusResponse_StateType = 1
	UNKNOWN StatusResponse_StateType = 2
)

func (StatusResponse_StateType) EnumDescriptor 

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

func (StatusResponse_StateType) String 

func (x StatusResponse_StateType) String() string

type Stop 

type Stop struct {
}

func (*Stop) Descriptor 

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

func (*Stop) Equal 

func (this *Stop) Equal(that interface{}) bool

func (*Stop) GoString 

func (this *Stop) GoString() string

func (*Stop) Marshal 

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

func (*Stop) MarshalTo 

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

func (*Stop) MarshalToSizedBuffer 

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

func (*Stop) ProtoMessage 

func (*Stop) ProtoMessage()

func (*Stop) Reset 

func (m *Stop) Reset()

func (*Stop) Size 

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

func (*Stop) String 

func (this *Stop) String() string

func (*Stop) Unmarshal 

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

func (*Stop) XXX_DiscardUnknown 

func (m *Stop) XXX_DiscardUnknown()

func (*Stop) XXX_Marshal 

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

func (*Stop) XXX_Merge 

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

func (*Stop) XXX_Size 

func (m *Stop) XXX_Size() int

func (*Stop) XXX_Unmarshal 

func (m *Stop) XXX_Unmarshal(b []byte) 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.