protobuf

package
v0.0.0-...-3295dff Latest Latest
Warning

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

Go to latest
Published: Feb 15, 2018 License: MIT Imports: 5 Imported by: 3

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

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) MarshalTo

func (m *NatsContext) MarshalTo(data []byte) (int, 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 Subject

type Subject int32
const (
	Subject_test_tests_unknown Subject = 0
	Subject_test_tests_get     Subject = 1
	Subject_test_tests_replace Subject = 2
	Subject_test_tests_delete  Subject = 3
	Subject_test_tests_find    Subject = 4
)

func (Subject) Enum

func (x Subject) Enum() *Subject

func (Subject) String

func (x Subject) String() string

func (*Subject) UnmarshalJSON

func (x *Subject) 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) MarshalTo

func (m *TestMessage) MarshalTo(data []byte) (int, 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

Jump to

Keyboard shortcuts

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