Documentation ¶
Overview ¶
Package protobuf is a generated protocol buffer package.
It is generated from these files:
nats.proto test.proto
It has these top-level messages:
NatsContext TestMessage
Index ¶
- Variables
- type NatsContext
- func (m *NatsContext) GetLastTrail() *NatsContext_Trail
- func (m *NatsContext) GetTraceId() string
- func (m *NatsContext) GetTrail() []*NatsContext_Trail
- func (m *NatsContext) Marshal() (data []byte, err error)
- func (m *NatsContext) MarshalTo(data []byte) (int, error)
- func (*NatsContext) ProtoMessage()
- func (m *NatsContext) Reset()
- func (m *NatsContext) Size() (n int)
- func (m *NatsContext) String() string
- func (m *NatsContext) Unmarshal(data []byte) error
- type NatsContext_Trail
- func (m *NatsContext_Trail) GetAppName() string
- func (m *NatsContext_Trail) GetDeadline() int64
- func (m *NatsContext_Trail) GetDeadlineNanos() int32
- func (m *NatsContext_Trail) GetDeadlineTs() *time.Time
- func (m *NatsContext_Trail) GetPutType() RequestType
- func (m *NatsContext_Trail) GetTime() int64
- func (m *NatsContext_Trail) GetTimeNanos() int32
- func (m *NatsContext_Trail) GetTimeTs() *time.Time
- func (m *NatsContext_Trail) Marshal() (data []byte, err error)
- func (m *NatsContext_Trail) MarshalTo(data []byte) (int, error)
- func (*NatsContext_Trail) ProtoMessage()
- func (m *NatsContext_Trail) Reset()
- func (m *NatsContext_Trail) SetDeadlineTs(ts time.Time)
- func (m *NatsContext_Trail) SetTimeTs(ts time.Time)
- func (m *NatsContext_Trail) Size() (n int)
- func (m *NatsContext_Trail) String() string
- func (m *NatsContext_Trail) Unmarshal(data []byte) error
- type RequestType
- type Subject
- type TestMessage
- func (m *TestMessage) GetContext() *NatsContext
- func (m *TestMessage) GetData() string
- func (m *TestMessage) Marshal() (data []byte, err error)
- func (m *TestMessage) MarshalTo(data []byte) (int, error)
- func (*TestMessage) ProtoMessage()
- func (m *TestMessage) Reset()
- func (m *TestMessage) Size() (n int)
- func (m *TestMessage) String() string
- func (m *TestMessage) Unmarshal(data []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthNats = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNats = fmt.Errorf("proto: integer overflow") )
View Source
var ( ErrInvalidLengthTest = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTest = fmt.Errorf("proto: integer overflow") )
View Source
var RequestType_name = map[int32]string{
0: "REQ",
1: "PUB",
2: "PUBREQ",
}
View Source
var RequestType_value = map[string]int32{
"REQ": 0,
"PUB": 1,
"PUBREQ": 2,
}
View Source
var Subject_name = map[int32]string{
0: "test_tests_unknown",
1: "test_tests_get",
2: "test_tests_replace",
3: "test_tests_delete",
4: "test_tests_find",
}
View Source
var Subject_value = map[string]int32{
"test_tests_unknown": 0,
"test_tests_get": 1,
"test_tests_replace": 2,
"test_tests_delete": 3,
"test_tests_find": 4,
}
Functions ¶
This section is empty.
Types ¶
type NatsContext ¶
type NatsContext struct { Trail []*NatsContext_Trail `protobuf:"bytes,1,rep,name=trail" json:"trail,omitempty"` TraceId *string `protobuf:"bytes,2,opt,name=trace_id" json:"trace_id,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*NatsContext) GetLastTrail ¶
func (m *NatsContext) GetLastTrail() *NatsContext_Trail
func (*NatsContext) GetTraceId ¶
func (m *NatsContext) GetTraceId() string
func (*NatsContext) GetTrail ¶
func (m *NatsContext) GetTrail() []*NatsContext_Trail
func (*NatsContext) Marshal ¶
func (m *NatsContext) Marshal() (data []byte, err error)
func (*NatsContext) ProtoMessage ¶
func (*NatsContext) ProtoMessage()
func (*NatsContext) Reset ¶
func (m *NatsContext) Reset()
func (*NatsContext) Size ¶
func (m *NatsContext) Size() (n int)
func (*NatsContext) String ¶
func (m *NatsContext) String() string
func (*NatsContext) Unmarshal ¶
func (m *NatsContext) Unmarshal(data []byte) error
type NatsContext_Trail ¶
type NatsContext_Trail struct { AppName *string `protobuf:"bytes,1,opt,name=app_name" json:"app_name,omitempty"` PutType *RequestType `protobuf:"varint,2,opt,name=put_type,enum=protobuf.RequestType" json:"put_type,omitempty"` Time *int64 `protobuf:"varint,3,opt,name=time" json:"time,omitempty"` TimeNanos *int32 `protobuf:"varint,4,opt,name=timeNanos" json:"timeNanos,omitempty"` Deadline *int64 `protobuf:"varint,5,opt,name=deadline" json:"deadline,omitempty"` DeadlineNanos *int32 `protobuf:"varint,6,opt,name=deadlineNanos" json:"deadlineNanos,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*NatsContext_Trail) GetAppName ¶
func (m *NatsContext_Trail) GetAppName() string
func (*NatsContext_Trail) GetDeadline ¶
func (m *NatsContext_Trail) GetDeadline() int64
func (*NatsContext_Trail) GetDeadlineNanos ¶
func (m *NatsContext_Trail) GetDeadlineNanos() int32
func (*NatsContext_Trail) GetDeadlineTs ¶
func (m *NatsContext_Trail) GetDeadlineTs() *time.Time
func (*NatsContext_Trail) GetPutType ¶
func (m *NatsContext_Trail) GetPutType() RequestType
func (*NatsContext_Trail) GetTime ¶
func (m *NatsContext_Trail) GetTime() int64
func (*NatsContext_Trail) GetTimeNanos ¶
func (m *NatsContext_Trail) GetTimeNanos() int32
func (*NatsContext_Trail) GetTimeTs ¶
func (m *NatsContext_Trail) GetTimeTs() *time.Time
func (*NatsContext_Trail) Marshal ¶
func (m *NatsContext_Trail) Marshal() (data []byte, err error)
func (*NatsContext_Trail) MarshalTo ¶
func (m *NatsContext_Trail) MarshalTo(data []byte) (int, error)
func (*NatsContext_Trail) ProtoMessage ¶
func (*NatsContext_Trail) ProtoMessage()
func (*NatsContext_Trail) Reset ¶
func (m *NatsContext_Trail) Reset()
func (*NatsContext_Trail) SetDeadlineTs ¶
func (m *NatsContext_Trail) SetDeadlineTs(ts time.Time)
func (*NatsContext_Trail) SetTimeTs ¶
func (m *NatsContext_Trail) SetTimeTs(ts time.Time)
func (*NatsContext_Trail) Size ¶
func (m *NatsContext_Trail) Size() (n int)
func (*NatsContext_Trail) String ¶
func (m *NatsContext_Trail) String() string
func (*NatsContext_Trail) Unmarshal ¶
func (m *NatsContext_Trail) Unmarshal(data []byte) error
type RequestType ¶
type RequestType int32
const ( RequestType_REQ RequestType = 0 RequestType_PUB RequestType = 1 RequestType_PUBREQ RequestType = 2 )
func (RequestType) Enum ¶
func (x RequestType) Enum() *RequestType
func (RequestType) String ¶
func (x RequestType) String() string
func (*RequestType) UnmarshalJSON ¶
func (x *RequestType) UnmarshalJSON(data []byte) error
type TestMessage ¶
type TestMessage struct { Context *NatsContext `protobuf:"bytes,1,opt,name=context" json:"context,omitempty"` Data *string `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*TestMessage) GetContext ¶
func (m *TestMessage) GetContext() *NatsContext
func (*TestMessage) GetData ¶
func (m *TestMessage) GetData() string
func (*TestMessage) Marshal ¶
func (m *TestMessage) Marshal() (data []byte, err error)
func (*TestMessage) ProtoMessage ¶
func (*TestMessage) ProtoMessage()
func (*TestMessage) Reset ¶
func (m *TestMessage) Reset()
func (*TestMessage) Size ¶
func (m *TestMessage) Size() (n int)
func (*TestMessage) String ¶
func (m *TestMessage) String() string
func (*TestMessage) Unmarshal ¶
func (m *TestMessage) Unmarshal(data []byte) error
Click to show internal directories.
Click to hide internal directories.