policy

package
v0.0.0-...-125528f Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Overview

Package policy is an implementation of policy.Manager feature.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
	Level                map[uint32]*Policy `` /* 152-byte string literal not displayed */
	System               *SystemPolicy      `protobuf:"bytes,2,opt,name=system,proto3" json:"system,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Config) Descriptor

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

func (*Config) GetLevel

func (m *Config) GetLevel() map[uint32]*Policy

func (*Config) GetSystem

func (m *Config) GetSystem() *SystemPolicy

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 Instance

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

Instance is an instance of Policy manager.

func New

func New(ctx context.Context, config *Config) (*Instance, error)

New creates new Policy manager instance.

func (*Instance) Close

func (m *Instance) Close() error

Close implements common.Closable.Close().

func (*Instance) ForLevel

func (m *Instance) ForLevel(level uint32) policy.Session

ForLevel implements policy.Manager.

func (*Instance) ForSystem

func (m *Instance) ForSystem() policy.System

ForSystem implements policy.Manager.

func (*Instance) Start

func (m *Instance) Start() error

Start implements common.Runnable.Start().

func (*Instance) Type

func (*Instance) Type() interface{}

Type implements common.HasType.

type Policy

type Policy struct {
	Timeout              *Policy_Timeout `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Stats                *Policy_Stats   `protobuf:"bytes,2,opt,name=stats,proto3" json:"stats,omitempty"`
	Buffer               *Policy_Buffer  `protobuf:"bytes,3,opt,name=buffer,proto3" json:"buffer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Policy) Descriptor

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

func (*Policy) GetBuffer

func (m *Policy) GetBuffer() *Policy_Buffer

func (*Policy) GetStats

func (m *Policy) GetStats() *Policy_Stats

func (*Policy) GetTimeout

func (m *Policy) GetTimeout() *Policy_Timeout

func (*Policy) ProtoMessage

func (*Policy) ProtoMessage()

func (*Policy) Reset

func (m *Policy) Reset()

func (*Policy) String

func (m *Policy) String() string

func (*Policy) ToCorePolicy

func (p *Policy) ToCorePolicy() policy.Session

ToCorePolicy converts this Policy to policy.Session.

func (*Policy) XXX_DiscardUnknown

func (m *Policy) XXX_DiscardUnknown()

func (*Policy) XXX_Marshal

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

func (*Policy) XXX_Merge

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

func (*Policy) XXX_Size

func (m *Policy) XXX_Size() int

func (*Policy) XXX_Unmarshal

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

type Policy_Buffer

type Policy_Buffer struct {
	// Buffer size per connection, in bytes. -1 for unlimited buffer.
	Connection           int32    `protobuf:"varint,1,opt,name=connection,proto3" json:"connection,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Policy_Buffer) Descriptor

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

func (*Policy_Buffer) GetConnection

func (m *Policy_Buffer) GetConnection() int32

func (*Policy_Buffer) ProtoMessage

func (*Policy_Buffer) ProtoMessage()

func (*Policy_Buffer) Reset

func (m *Policy_Buffer) Reset()

func (*Policy_Buffer) String

func (m *Policy_Buffer) String() string

func (*Policy_Buffer) XXX_DiscardUnknown

func (m *Policy_Buffer) XXX_DiscardUnknown()

func (*Policy_Buffer) XXX_Marshal

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

func (*Policy_Buffer) XXX_Merge

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

func (*Policy_Buffer) XXX_Size

func (m *Policy_Buffer) XXX_Size() int

func (*Policy_Buffer) XXX_Unmarshal

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

type Policy_Stats

type Policy_Stats struct {
	UserUplink           bool     `protobuf:"varint,1,opt,name=user_uplink,json=userUplink,proto3" json:"user_uplink,omitempty"`
	UserDownlink         bool     `protobuf:"varint,2,opt,name=user_downlink,json=userDownlink,proto3" json:"user_downlink,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Policy_Stats) Descriptor

func (*Policy_Stats) Descriptor() ([]byte, []int)
func (m *Policy_Stats) GetUserDownlink() bool
func (m *Policy_Stats) GetUserUplink() bool

func (*Policy_Stats) ProtoMessage

func (*Policy_Stats) ProtoMessage()

func (*Policy_Stats) Reset

func (m *Policy_Stats) Reset()

func (*Policy_Stats) String

func (m *Policy_Stats) String() string

func (*Policy_Stats) XXX_DiscardUnknown

func (m *Policy_Stats) XXX_DiscardUnknown()

func (*Policy_Stats) XXX_Marshal

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

func (*Policy_Stats) XXX_Merge

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

func (*Policy_Stats) XXX_Size

func (m *Policy_Stats) XXX_Size() int

func (*Policy_Stats) XXX_Unmarshal

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

type Policy_Timeout

type Policy_Timeout struct {
	Handshake            *Second  `protobuf:"bytes,1,opt,name=handshake,proto3" json:"handshake,omitempty"`
	ConnectionIdle       *Second  `protobuf:"bytes,2,opt,name=connection_idle,json=connectionIdle,proto3" json:"connection_idle,omitempty"`
	UplinkOnly           *Second  `protobuf:"bytes,3,opt,name=uplink_only,json=uplinkOnly,proto3" json:"uplink_only,omitempty"`
	DownlinkOnly         *Second  `protobuf:"bytes,4,opt,name=downlink_only,json=downlinkOnly,proto3" json:"downlink_only,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Timeout is a message for timeout settings in various stages, in seconds.

func (*Policy_Timeout) Descriptor

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

func (*Policy_Timeout) GetConnectionIdle

func (m *Policy_Timeout) GetConnectionIdle() *Second

func (*Policy_Timeout) GetDownlinkOnly

func (m *Policy_Timeout) GetDownlinkOnly() *Second

func (*Policy_Timeout) GetHandshake

func (m *Policy_Timeout) GetHandshake() *Second

func (*Policy_Timeout) GetUplinkOnly

func (m *Policy_Timeout) GetUplinkOnly() *Second

func (*Policy_Timeout) ProtoMessage

func (*Policy_Timeout) ProtoMessage()

func (*Policy_Timeout) Reset

func (m *Policy_Timeout) Reset()

func (*Policy_Timeout) String

func (m *Policy_Timeout) String() string

func (*Policy_Timeout) XXX_DiscardUnknown

func (m *Policy_Timeout) XXX_DiscardUnknown()

func (*Policy_Timeout) XXX_Marshal

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

func (*Policy_Timeout) XXX_Merge

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

func (*Policy_Timeout) XXX_Size

func (m *Policy_Timeout) XXX_Size() int

func (*Policy_Timeout) XXX_Unmarshal

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

type Second

type Second struct {
	Value                uint32   `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Second) Descriptor

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

func (*Second) Duration

func (s *Second) Duration() time.Duration

Duration converts Second to time.Duration.

func (*Second) GetValue

func (m *Second) GetValue() uint32

func (*Second) ProtoMessage

func (*Second) ProtoMessage()

func (*Second) Reset

func (m *Second) Reset()

func (*Second) String

func (m *Second) String() string

func (*Second) XXX_DiscardUnknown

func (m *Second) XXX_DiscardUnknown()

func (*Second) XXX_Marshal

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

func (*Second) XXX_Merge

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

func (*Second) XXX_Size

func (m *Second) XXX_Size() int

func (*Second) XXX_Unmarshal

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

type SystemPolicy

type SystemPolicy struct {
	Stats                *SystemPolicy_Stats `protobuf:"bytes,1,opt,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SystemPolicy) Descriptor

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

func (*SystemPolicy) GetStats

func (m *SystemPolicy) GetStats() *SystemPolicy_Stats

func (*SystemPolicy) ProtoMessage

func (*SystemPolicy) ProtoMessage()

func (*SystemPolicy) Reset

func (m *SystemPolicy) Reset()

func (*SystemPolicy) String

func (m *SystemPolicy) String() string

func (*SystemPolicy) ToCorePolicy

func (p *SystemPolicy) ToCorePolicy() policy.System

ToCorePolicy converts this SystemPolicy to policy.System.

func (*SystemPolicy) XXX_DiscardUnknown

func (m *SystemPolicy) XXX_DiscardUnknown()

func (*SystemPolicy) XXX_Marshal

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

func (*SystemPolicy) XXX_Merge

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

func (*SystemPolicy) XXX_Size

func (m *SystemPolicy) XXX_Size() int

func (*SystemPolicy) XXX_Unmarshal

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

type SystemPolicy_Stats

type SystemPolicy_Stats struct {
	InboundUplink        bool     `protobuf:"varint,1,opt,name=inbound_uplink,json=inboundUplink,proto3" json:"inbound_uplink,omitempty"`
	InboundDownlink      bool     `protobuf:"varint,2,opt,name=inbound_downlink,json=inboundDownlink,proto3" json:"inbound_downlink,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SystemPolicy_Stats) Descriptor

func (*SystemPolicy_Stats) Descriptor() ([]byte, []int)
func (m *SystemPolicy_Stats) GetInboundDownlink() bool
func (m *SystemPolicy_Stats) GetInboundUplink() bool

func (*SystemPolicy_Stats) ProtoMessage

func (*SystemPolicy_Stats) ProtoMessage()

func (*SystemPolicy_Stats) Reset

func (m *SystemPolicy_Stats) Reset()

func (*SystemPolicy_Stats) String

func (m *SystemPolicy_Stats) String() string

func (*SystemPolicy_Stats) XXX_DiscardUnknown

func (m *SystemPolicy_Stats) XXX_DiscardUnknown()

func (*SystemPolicy_Stats) XXX_Marshal

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

func (*SystemPolicy_Stats) XXX_Merge

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

func (*SystemPolicy_Stats) XXX_Size

func (m *SystemPolicy_Stats) XXX_Size() int

func (*SystemPolicy_Stats) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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