transport

Documentation

Index

• Variables
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (x *Message) GetCompleted() *timestamp.Timestamp
  • func (x *Message) GetCreated() *timestamp.Timestamp
  • func (x *Message) GetError() string
  • func (x *Message) GetExecutionTime() *duration.Duration
  • func (x *Message) GetId() string
  • func (x *Message) GetOriginId() string
  • func (x *Message) GetPriority() shared.Priority
  • func (x *Message) GetReceived() *timestamp.Timestamp
  • func (x *Message) GetSnmpc() *snmpc.Task
  • func (x *Message) GetSource() string
  • func (x *Message) GetSsh() *ssh.Task
  • func (x *Message) GetStarted() *timestamp.Timestamp
  • func (x *Message) GetStatus() shared.Status
  • func (x *Message) GetTags() map[string]*any.Any
  • func (x *Message) GetTarget() string
  • func (m *Message) GetTask() isMessage_Task
  • func (x *Message) GetTelnet() *telnet.Task
  • func (x *Message) GetType() Type
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type Message_Snmpc
• type Message_Ssh
• type Message_Telnet
• type Type
  • func (Type) Descriptor() protoreflect.EnumDescriptor
  • func (x Type) Enum() *Type
  • func (Type) EnumDescriptor() ([]byte, []int)
  • func (x Type) Number() protoreflect.EnumNumber
  • func (x Type) String() string
  • func (Type) Type() protoreflect.EnumType

Variables

var (
	Type_name = map[int32]string{
		0: "TELNET",
		1: "SNMP",
		2: "SSH",
	}
	Type_value = map[string]int32{
		"TELNET": 0,
		"SNMP":   1,
		"SSH":    2,
	}
)

Enum value maps for Type.

var File_git_liero_se_opentelco_go_dnc_proto_transport_proto protoreflect.FileDescriptor

Types

type Message

type Message struct {
	Id       string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OriginId string          `protobuf:"bytes,2,opt,name=origin_id,json=originId,proto3" json:"origin_id,omitempty"`
	Status   shared.Status   `protobuf:"varint,3,opt,name=status,proto3,enum=dnc.shared.Status" json:"status,omitempty"`
	Type     Type            `protobuf:"varint,4,opt,name=type,proto3,enum=dnc.transport.Type" json:"type,omitempty"`
	Target   string          `protobuf:"bytes,5,opt,name=target,proto3" json:"target,omitempty"`
	Source   string          `protobuf:"bytes,6,opt,name=source,proto3" json:"source,omitempty"`
	Priority shared.Priority `protobuf:"varint,7,opt,name=priority,proto3,enum=dnc.shared.Priority" json:"priority,omitempty"`
	// Types that are assignable to Task:
	//	*Message_Snmpc
	//	*Message_Telnet
	//	*Message_Ssh
	Task          isMessage_Task       `protobuf_oneof:"task"`
	Tags          map[string]*any.Any  `` /* 150-byte string literal not displayed */
	Error         string               `protobuf:"bytes,11,opt,name=error,proto3" json:"error,omitempty"`
	Created       *timestamp.Timestamp `protobuf:"bytes,13,opt,name=created,proto3" json:"created,omitempty"`
	Received      *timestamp.Timestamp `protobuf:"bytes,14,opt,name=received,proto3" json:"received,omitempty"`
	Started       *timestamp.Timestamp `protobuf:"bytes,15,opt,name=started,proto3" json:"started,omitempty"`
	Completed     *timestamp.Timestamp `protobuf:"bytes,16,opt,name=completed,proto3" json:"completed,omitempty"`
	ExecutionTime *duration.Duration   `protobuf:"bytes,17,opt,name=execution_time,json=executionTime,proto3" json:"execution_time,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetCompleted

func (x *Message) GetCompleted() *timestamp.Timestamp

func (*Message) GetCreated

func (x *Message) GetCreated() *timestamp.Timestamp

func (*Message) GetError

func (x *Message) GetError() string

func (*Message) GetExecutionTime

func (x *Message) GetExecutionTime() *duration.Duration

func (*Message) GetId

func (x *Message) GetId() string

func (*Message) GetOriginId

func (x *Message) GetOriginId() string

func (*Message) GetPriority

func (x *Message) GetPriority() shared.Priority

func (*Message) GetReceived

func (x *Message) GetReceived() *timestamp.Timestamp

func (*Message) GetSnmpc

func (x *Message) GetSnmpc() *snmpc.Task

func (*Message) GetSource

func (x *Message) GetSource() string

func (*Message) GetSsh

func (x *Message) GetSsh() *ssh.Task

func (*Message) GetStarted

func (x *Message) GetStarted() *timestamp.Timestamp

func (*Message) GetStatus

func (x *Message) GetStatus() shared.Status

func (*Message) GetTags

func (x *Message) GetTags() map[string]*any.Any

func (*Message) GetTarget

func (x *Message) GetTarget() string

func (*Message) GetTask

func (m *Message) GetTask() isMessage_Task

func (*Message) GetTelnet

func (x *Message) GetTelnet() *telnet.Task

func (*Message) GetType

func (x *Message) GetType() Type

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type Message_Snmpc

type Message_Snmpc struct {
	Snmpc *snmpc.Task `protobuf:"bytes,8,opt,name=snmpc,proto3,oneof"`
}

type Message_Ssh

type Message_Ssh struct {
	Ssh *ssh.Task `protobuf:"bytes,18,opt,name=ssh,proto3,oneof"`
}

type Message_Telnet

type Message_Telnet struct {
	Telnet *telnet.Task `protobuf:"bytes,9,opt,name=telnet,proto3,oneof"`
}

type Type

type Type int32

const (
	Type_TELNET Type = 0
	Type_SNMP   Type = 1
	Type_SSH    Type = 2
)

func (Type) Descriptor

func (Type) Descriptor() protoreflect.EnumDescriptor

func (Type) Enum

func (x Type) Enum() *Type

func (Type) EnumDescriptor

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

Deprecated: Use Type.Descriptor instead.

func (Type) Number

func (x Type) Number() protoreflect.EnumNumber

func (Type) String

func (x Type) String() string

func (Type) Type

func (Type) Type() protoreflect.EnumType