gosiris

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

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

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

type ActorRefInterface interface {
	Tell(Context, string, interface{}, ActorRefInterface) error
	Repeat(string, time.Duration, interface{}, ActorRefInterface) (chan struct{}, error)
	AskForClose(ActorRefInterface)
	LogInfo(Context, string, ...interface{})
	LogError(Context, string, ...interface{})
	Become(string, func(Context)) error
	Unbecome(string) error
	Name() string
	Forward(Context, ...string)
}

type Context struct {
	MessageType string
	Data        interface{}
	Sender      ActorRefInterface
	Self        ActorRefInterface
	// contains filtered or unexported fields
}

type OptionsInterface interface {
	SetUrl(string) OptionsInterface
	SetRemote(bool) OptionsInterface
	SetAutoclose(bool) OptionsInterface
	Remote() bool
	Autoclose() bool
	SetRemoteType(string) OptionsInterface
	RemoteType() string
	Url() string
	SetDestination(string) OptionsInterface
	Destination() string

	Parent() string
	SetBufferSize(int) OptionsInterface
	BufferSize() int
	SetDefaultWatcher(time.Duration) OptionsInterface
	DefaultWatcher() time.Duration
	// contains filtered or unexported methods
}

type RemoteActor struct {
	Actor
}

type SystemOptions struct {
	ActorSystemName string
	ZipkinOptions   ZipkinOptions
	RegistryUrl     string
}

type TransportInterface interface {
	Configure(string, map[string]string)
	Connection() error
	Send(string, []byte) error
	Receive(string)
	Close()
}

type ZipkinOptions struct {
	Url      string
	Debug    bool
	HostPort string
	SameSpan bool
}