scamp

package

Go to main page

Versions in this module

v0

v0.14.1

Jan 2, 2020

v0.14.0

Dec 19, 2019

Changes in this version

type Config

+ func (conf *Config) RunningServiceFileDirPath() (runningServiceFileDirPath []byte, err error)

v0.13.3

Jun 18, 2019

v0.13.2

Apr 25, 2019

Changes in this version

+ const MAX_RETRIES

v0.13.1

Apr 8, 2019

Changes in this version

+ func ReplyOnError(message *Message, client *Client, errorCode string, err error)

+ type ActionOptions struct

+ Privs []int

+ TicketVerifyPublicKey string

+ Verify bool

+ func DefaultActionOptions() ActionOptions

+ type BasicActionFunc func(*Message, *Client)

+ func (function BasicActionFunc) Call(message *Message, client *Client)

type ServiceActionFunc

+ Call func(*Message, *Client)

+ type ServiceOptionsFunc struct

+ func (function ServiceOptionsFunc) Call(message *Message, client *Client)

type Ticket

+ Privileges map[int]bool

+ Timestamp int64

+ func VerifyTicket(unparsedTicket string, keyPath string) (*Ticket, error)

+ func (ticket *Ticket) CheckPrivs(privs []int) error

v0.12.1

Aug 21, 2018

Changes in this version

type Config

+ func (conf *Config) LocalDiscoveryMulticast() bool

v0.10.9

Jul 26, 2018

Changes in this version

type ServiceCache

+ var DefaultCache *ServiceCache

v0.10.8

Jun 19, 2018

v0.10.7

Apr 4, 2018

v0.10.5

Jan 30, 2018

Changes in this version

+ const RetryLimit

v0.10.4

Dec 26, 2017

Changes in this version

+ const EnvelopeJSON

+ const EnvelopeJSONSTORE

+ const MessageTypeReply

+ const MessageTypeRequest

+ var MaxRetries = 10

+ func Do(fn Func) error

+ func GetSHA1FingerPrint(cert *x509.Certificate) (hexSha1 string)

+ func IsMaxRetries(err error) bool

+ type Func func(attempt int) (retry bool, err error)

type Message

+ RequestID int

+ func MakeJSONRequest(sector, action string, version int, msg *Message) (message *Message, err error)

+ func (msg *Message) SetRequestID(requestID int)

+ func (msg *Message) WriteJSON(data interface{}) (n int, err error)

type PacketHeader

+ RequestID int

type Ticket

+ ClientID int64

+ TTL int

+ UserID int64

v0.10.3

Nov 15, 2017

v0.10.2

Nov 9, 2017

v0.10.1

Oct 28, 2017

Changes in this version

+ const ENVELOPE_JSON

+ const ENVELOPE_JSONSTORE

+ const MESSAGE_TYPE_REPLY

+ const MESSAGE_TYPE_REQUEST

+ var DefaultConfigPath = "/etc/SCAMP/soa.conf"

+ var Error *log.Logger

+ var Info *log.Logger

+ var MSG_CHUNK_SIZE = 256 * 1024

+ var Trace *log.Logger

+ var Warning *log.Logger

+ func IPForAnnouncePacket() (ip net.IP, err error)

+ func Initialize(configPath string) (err error)

+ func LocalMulticastPacketConn() (conn *ipv4.PacketConn, err error)

+ func LoopbackInterface() (lo *net.Interface, err error)

+ func MakeJsonRequest(sector, action string, version int, msg *Message) (responseChan chan *Message, err error)

+ func PrintStatsLoop(service *Service, timeout time.Duration, closeChan chan bool)

+ func SHA1FingerPrint(cert *x509.Certificate) (hexSha1 string)

+ func SetDefaultConfig(conf *Config)

+ func SignSHA256(rawPayload []byte, priv *rsa.PrivateKey) (base64signature string, err error)

+ func VerifySHA256(rawPayload []byte, rsaPubKey *rsa.PublicKey, encodedSignature []byte, ...) (err error)

+ type ActionDescription struct

+ func (ad ActionDescription) Name() string

+ func (ad ActionDescription) Version() int

+ type AuthorizedServiceSpec struct

+ Actions []ServiceProxyClass

+ Fingerprint []byte

+ func NewAuthorizedServicesSpec(line []byte) (spec *AuthorizedServiceSpec, err error)

+ type AuthorizedServicesCache struct

+ func NewAuthorizedServicesCache() (cache *AuthorizedServicesCache)

+ func (cache *AuthorizedServicesCache) LoadAuthorizedServices(s *bufio.Scanner) (err error)

+ type Client struct

+ func Dial(connspec string) (client *Client, err error)

+ func NewClient(conn *Connection) (client *Client)

+ func (client *Client) Close()

+ func (client *Client) Incoming() MessageChan

+ func (client *Client) Send(msg *Message) (responseChan MessageChan, err error)

+ func (client *Client) SetService(serv *Service)

+ type ClientChan chan *Client

+ type Config struct

+ func DefaultConfig() (conf *Config)

+ func NewConfig() (conf *Config)

+ func (conf *Config) DiscoveryMulticastIP() (ip net.IP)

+ func (conf *Config) DiscoveryMulticastPort() (port int)

+ func (conf *Config) Get(key string) (value string, ok bool)

+ func (conf *Config) Load(configPath string) (err error)

+ func (conf *Config) ServiceCertPath(serviceName string) (certPath []byte)

+ func (conf *Config) ServiceKeyPath(serviceName string) (keyPath []byte)

+ func (conf *Config) Set(key string, value string)

+ type Connection struct

+ Fingerprint string

+ func DialConnection(connspec string) (conn *Connection, err error)

+ func NewConnection(tlsConn *tls.Conn, connType string) (conn *Connection)

+ func (conn *Connection) Close()

+ func (conn *Connection) Send(msg *Message) (err error)

+ func (conn *Connection) SetClient(client *Client)

+ type DiscoveryAnnouncer struct

+ func NewDiscoveryAnnouncer() (announcer *DiscoveryAnnouncer, err error)

+ func (announcer *DiscoveryAnnouncer) AnnounceLoop()

+ func (announcer *DiscoveryAnnouncer) Stop()

+ func (announcer *DiscoveryAnnouncer) Track(serv *Service)

+ type HighResTimestamp float64

+ func Gettimeofday() (ts HighResTimestamp, err error)

+ func (ts HighResTimestamp) MarshalJSON() ([]byte, error)

+ type IncomingMsgNo uint64

+ type Message struct

+ Action string

+ Envelope envelopeFormat

+ Error string

+ ErrorCode string

+ IdentifyingToken string

+ MessageType messageType

+ RequestId int

+ Ticket string

+ Version int

+ func NewMessage() (msg *Message)

+ func NewRequestMessage() (msg *Message)

+ func NewResponseMessage() (msg *Message)

+ func (msg *Message) Bytes() []byte

+ func (msg *Message) BytesWritten() uint64

+ func (msg *Message) GetError() (err string)

+ func (msg *Message) GetErrorCode() (errCode string)

+ func (msg *Message) GetIdentifyingToken() (token string)

+ func (msg *Message) GetTicket() (ticket string)

+ func (msg *Message) SetAction(action string)

+ func (msg *Message) SetEnvelope(env envelopeFormat)

+ func (msg *Message) SetError(err string)

+ func (msg *Message) SetErrorCode(errCode string)

+ func (msg *Message) SetIdentifyingToken(token string)

+ func (msg *Message) SetMessageType(mtype messageType)

+ func (msg *Message) SetRequestId(requestId int)

+ func (msg *Message) SetTicket(ticket string)

+ func (msg *Message) SetVersion(version int)

+ func (msg *Message) Write(blob []byte) (n int, err error)

+ func (msg *Message) WriteJson(data interface{}) (n int, err error)

+ type MessageChan chan *Message

+ type NullWriter int

+ func (NullWriter) Write([]byte) (int, error)

+ type OutgoingMsgNo uint64

+ type Packet struct

+ func ReadPacket(reader *bufio.ReadWriter) (pkt *Packet, err error)

+ func (pkt *Packet) Write(writer io.Writer) (written int, err error)

+ type PacketHeader struct

+ Action string

+ Envelope envelopeFormat

+ Error string

+ ErrorCode string

+ IdentifyingToken string

+ MessageType messageType

+ RequestId int

+ Ticket string

+ Version int

+ func (pktHdr *PacketHeader) Write(writer io.Writer) (err error)

+ type PacketType int

+ const ACK

+ const DATA

+ const EOF

+ const HEADER

+ const TXERR

+ type ScampDebugger struct

+ func NewScampDebugger(conn *tls.Conn, clientType string) (handle *ScampDebugger, err error)

+ func (handle *ScampDebugger) ReadWriter(p []byte) (n int, err error)

+ func (handle *ScampDebugger) Write(p []byte) (n int, err error)

+ type ScampDebuggerReader struct

+ func (sdr *ScampDebuggerReader) Write(p []byte) (n int, err error)

+ type Service struct

+ func NewService(sector string, serviceSpec string, humanName string) (*Service, error)

+ func NewServiceExplicitCert(sector string, serviceSpec string, humanName string, keypair tls.Certificate, ...) (serv *Service, err error)

+ func (serv *Service) Handle(client *Client)

+ func (serv *Service) MarshalText() (b []byte, err error)

+ func (serv *Service) Register(name string, callback ServiceActionFunc) (err error)

+ func (serv *Service) RemoveClient(client *Client) (err error)

+ func (serv *Service) Run()

+ func (serv *Service) Stop()

+ type ServiceAction struct

+ type ServiceActionFunc func(*Message, *Client)

+ type ServiceCache struct

+ func NewServiceCache(path string) (cache *ServiceCache, err error)

+ func (cache *ServiceCache) All() (proxies []*ServiceProxy)

+ func (cache *ServiceCache) DisableRecordVerification()

+ func (cache *ServiceCache) DoScan(s *bufio.Scanner) (err error)

+ func (cache *ServiceCache) EnableRecordVerification()

+ func (cache *ServiceCache) Refresh() (err error)

+ func (cache *ServiceCache) Retrieve(ident string) (instance *ServiceProxy)

+ func (cache *ServiceCache) SearchByAction(sector, action string, version int, envelope string) (instances []*ServiceProxy)

+ func (cache *ServiceCache) Size() int

+ func (cache *ServiceCache) Store(instance *ServiceProxy)

+ type ServiceProxy struct

+ func NewServiceProxy(classRecordsRaw []byte, certRaw []byte, sigRaw []byte) (proxy *ServiceProxy, err error)

+ func ServiceAsServiceProxy(serv *Service) (proxy *ServiceProxy)

+ func (proxy *ServiceProxy) GetConnection() (client *Client, err error)

+ func (proxy *ServiceProxy) MarshalJSON() (b []byte, err error)

+ func (proxy *ServiceProxy) Validate() (err error)

+ func (sp *ServiceProxy) Classes() []ServiceProxyClass

+ func (sp ServiceProxy) BaseIdent() string

+ func (sp ServiceProxy) ConnSpec() string

+ func (sp ServiceProxy) GetClient() (client *Client, err error)

+ func (sp ServiceProxy) Ident() string

+ func (sp ServiceProxy) Sector() string

+ func (sp ServiceProxy) ShortHostname() string

+ type ServiceProxyClass struct

+ func (spc ServiceProxyClass) Actions() []ActionDescription

+ func (spc ServiceProxyClass) Name() string

+ type ServiceProxyDiscoveryExtension struct

+ AcEnv []interface{}

+ AcFlag []interface{}

+ AcName []string

+ AcNs []interface{}

+ AcSec []interface{}

+ AcVer []interface{}

+ Vmaj int

+ Vmin int

+ type ServiceStats struct

+ ClientsAccepted uint64

+ OpenConnections uint64

+ func GatherStats(service *Service) (stats ServiceStats)

+ type Ticket struct

+ ClientId int64

+ Expired bool

+ Ttl int

+ UserId int64

+ ValidityEnd int64

+ ValidityStart int64

+ Version int64

+ func ReadTicket(incoming []byte, signingPubKey []byte) (ticket Ticket, err error)

+ func ReadTicketNoVerify(incoming []byte) (ticket Ticket, err error)

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