reqresp_pb

Documentation

Index

• Variables
• type IngestMessage
  • func (*IngestMessage) Descriptor() ([]byte, []int)
  • func (m *IngestMessage) GetData() []byte
  • func (m *IngestMessage) GetType() IngestMessage_MessageType
  • func (m *IngestMessage) Marshal() (dAtA []byte, err error)
  • func (m *IngestMessage) MarshalTo(dAtA []byte) (int, error)
  • func (m *IngestMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*IngestMessage) ProtoMessage()
  • func (m *IngestMessage) Reset()
  • func (m *IngestMessage) Size() (n int)
  • func (m *IngestMessage) String() string
  • func (m *IngestMessage) Unmarshal(dAtA []byte) error
  • func (m *IngestMessage) XXX_DiscardUnknown()
  • func (m *IngestMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *IngestMessage) XXX_Merge(src proto.Message)
  • func (m *IngestMessage) XXX_Size() int
  • func (m *IngestMessage) XXX_Unmarshal(b []byte) error
• type IngestMessage_MessageType
  • func (IngestMessage_MessageType) EnumDescriptor() ([]byte, []int)
  • func (x IngestMessage_MessageType) String() string

Variables

var (
	ErrInvalidLengthIngest        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowIngest          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupIngest = fmt.Errorf("proto: unexpected end of group")
)

var IngestMessage_MessageType_name = map[int32]string{
	0: "ERROR_RESPONSE",
	1: "DISCOVER_PROVIDER",
	2: "DISCOVER_PROVIDER_RESPONSE",
	3: "REGISTER_PROVIDER",
	4: "REGISTER_PROVIDER_RESPONSE",
	5: "REMOVE_PROVIDER",
	6: "REMOVE_PROVIDER_RESPONSE",
	7: "INDEX_CONTENT",
	8: "INDEX_CONTENT_RESPONSE",
}

var IngestMessage_MessageType_value = map[string]int32{
	"ERROR_RESPONSE":             0,
	"DISCOVER_PROVIDER":          1,
	"DISCOVER_PROVIDER_RESPONSE": 2,
	"REGISTER_PROVIDER":          3,
	"REGISTER_PROVIDER_RESPONSE": 4,
	"REMOVE_PROVIDER":            5,
	"REMOVE_PROVIDER_RESPONSE":   6,
	"INDEX_CONTENT":              7,
	"INDEX_CONTENT_RESPONSE":     8,
}

Types

type IngestMessage

type IngestMessage struct {
	// defines what type of message it is.
	Type IngestMessage_MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=reqresp.pb.IngestMessage_MessageType" json:"type,omitempty"`
	// Value for the message
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*IngestMessage) Descriptor

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

func (*IngestMessage) GetData

func (m *IngestMessage) GetData() []byte

func (*IngestMessage) GetType

func (m *IngestMessage) GetType() IngestMessage_MessageType

func (*IngestMessage) Marshal

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

func (*IngestMessage) MarshalTo

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

func (*IngestMessage) MarshalToSizedBuffer

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

func (*IngestMessage) ProtoMessage

func (*IngestMessage) ProtoMessage()

func (*IngestMessage) Reset

func (m *IngestMessage) Reset()

func (*IngestMessage) Size

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

func (*IngestMessage) String

func (m *IngestMessage) String() string

func (*IngestMessage) Unmarshal

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

func (*IngestMessage) XXX_DiscardUnknown

func (m *IngestMessage) XXX_DiscardUnknown()

func (*IngestMessage) XXX_Marshal

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

func (*IngestMessage) XXX_Merge

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

func (*IngestMessage) XXX_Size

func (m *IngestMessage) XXX_Size() int

func (*IngestMessage) XXX_Unmarshal

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

type IngestMessage_MessageType

type IngestMessage_MessageType int32

const (
	IngestMessage_ERROR_RESPONSE             IngestMessage_MessageType = 0
	IngestMessage_DISCOVER_PROVIDER          IngestMessage_MessageType = 1
	IngestMessage_DISCOVER_PROVIDER_RESPONSE IngestMessage_MessageType = 2
	IngestMessage_REGISTER_PROVIDER          IngestMessage_MessageType = 3
	IngestMessage_REGISTER_PROVIDER_RESPONSE IngestMessage_MessageType = 4
	IngestMessage_REMOVE_PROVIDER            IngestMessage_MessageType = 5
	IngestMessage_REMOVE_PROVIDER_RESPONSE   IngestMessage_MessageType = 6
	IngestMessage_INDEX_CONTENT              IngestMessage_MessageType = 7
	IngestMessage_INDEX_CONTENT_RESPONSE     IngestMessage_MessageType = 8
)

func (IngestMessage_MessageType) EnumDescriptor

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

func (IngestMessage_MessageType) String

func (x IngestMessage_MessageType) String() string