commander

package

v4.15.0+incompatible Latest Latest Go to latest Published: Feb 7, 2019 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/v2ray/v2ray-core

Links

Open Source Insights

Documentation ¶

Index ¶

type Commander
- func NewCommander(ctx context.Context, config *Config) (*Commander, error)
type Config
type Outbound
type OutboundListener
type Service

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Commander ¶

type Commander struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Commander is a V2Ray feature that provides gRPC methods to external clients.

func NewCommander ¶

func NewCommander(ctx context.Context, config *Config) (*Commander, error)

NewCommander creates a new Commander based on the given config.

func (*Commander) Close ¶

func (c *Commander) Close() error

Close implements common.Closable.

func (*Commander) Start ¶

func (c *Commander) Start() error

Start implements common.Runnable.

func (*Commander) Type ¶

func (c *Commander) Type() interface{}

Type implements common.HasType.

type Config ¶

type Config struct {
	// Tag of the outbound handler that handles grpc connections.
	Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	// Services that supported by this server. All services must implement Service interface.
	Service              []*serial.TypedMessage `protobuf:"bytes,2,rep,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

Config is the settings for Commander.

func (*Config) Descriptor ¶

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

func (*Config) GetService ¶

func (m *Config) GetService() []*serial.TypedMessage

func (*Config) GetTag ¶

func (m *Config) GetTag() string

func (*Config) ProtoMessage ¶

func (*Config) ProtoMessage()

func (*Config) Reset ¶

func (m *Config) Reset()

func (*Config) String ¶

func (m *Config) String() string

func (*Config) XXX_DiscardUnknown ¶

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal ¶

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

func (*Config) XXX_Merge ¶

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

func (*Config) XXX_Size ¶

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal ¶

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

type Outbound ¶

type Outbound struct {
	// contains filtered or unexported fields
}

Outbound is a outbound.Handler that handles gRPC connections.

func (*Outbound) Close ¶

func (co *Outbound) Close() error

Close implements common.Closable.

func (*Outbound) Dispatch ¶

func (co *Outbound) Dispatch(ctx context.Context, link *transport.Link)

Dispatch implements outbound.Handler.

func (*Outbound) Start ¶

func (co *Outbound) Start() error

Start implements common.Runnable.

func (*Outbound) Tag ¶

func (co *Outbound) Tag() string

Tag implements outbound.Handler.

type OutboundListener ¶

type OutboundListener struct {
	// contains filtered or unexported fields
}

OutboundListener is a net.Listener for listening gRPC connections.

func (*OutboundListener) Accept ¶

func (l *OutboundListener) Accept() (net.Conn, error)

Accept implements net.Listener.

func (*OutboundListener) Addr ¶

func (l *OutboundListener) Addr() net.Addr

Addr implements net.Listener.

func (*OutboundListener) Close ¶

func (l *OutboundListener) Close() error

Close implement net.Listener.

type Service ¶

type Service interface {
	// Register registers the service itself to a gRPC server.
	Register(*grpc.Server)
}

Service is a Commander service.

Source Files ¶

View all Source files

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