multi

package
v0.5.39 Latest Latest
Warning

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

 Go to latest Published: Jun 29, 2024 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Commands = map[string]*tool.Command{
		"deploy": &deployCmd,
		"logs": tool.LogsCmd(&tool.LogsSpec{
			Tool: "weaver multi",
			Source: func(context.Context) (logging.Source, error) {
				return logging.FileSource(logDir), nil
			},
		}),
		"dashboard": status.DashboardCommand(dashboardSpec),
		"status":    status.StatusCommand("weaver multi", defaultRegistry),
		"metrics":   status.MetricsCommand("weaver multi", defaultRegistry),
		"profile":   status.ProfileCommand("weaver multi", defaultRegistry),
		"purge":     tool.PurgeCmd(purgeSpec),
		"version":   itool.VersionCmd("weaver multi"),
	}
)
View Source 
var File_internal_tool_multi_multi_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type MultiConfig 

type MultiConfig struct {

	// Application config.
	App *protos.AppConfig `protobuf:"bytes,1,opt,name=app,proto3" json:"app,omitempty"`
	// Should the components use the mTLS protocol to communicate with
	// one another?
	Mtls           bool                                         `protobuf:"varint,2,opt,name=mtls,proto3" json:"mtls,omitempty"`
	Listeners      map[string]*MultiConfig_ListenerOptions      `` /* 159-byte string literal not displayed */
	AntipodeAgents map[string]*MultiConfig_AntipodeAgentOptions `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

MultiConfig stores the configuration information for one execution of a Service Weaver application using the multiprocess deployer.

func (*MultiConfig) Descriptor deprecated 

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

Deprecated: Use MultiConfig.ProtoReflect.Descriptor instead.

func (*MultiConfig) GetAntipodeAgents added in v0.4.84 

func (x *MultiConfig) GetAntipodeAgents() map[string]*MultiConfig_AntipodeAgentOptions

func (*MultiConfig) GetApp 

func (x *MultiConfig) GetApp() *protos.AppConfig

func (*MultiConfig) GetListeners 

func (x *MultiConfig) GetListeners() map[string]*MultiConfig_ListenerOptions

func (*MultiConfig) GetMtls 

func (x *MultiConfig) GetMtls() bool

func (*MultiConfig) ProtoMessage 

func (*MultiConfig) ProtoMessage()

func (*MultiConfig) ProtoReflect 

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

func (*MultiConfig) Reset 

func (x *MultiConfig) Reset()

func (*MultiConfig) String 

func (x *MultiConfig) String() string

type MultiConfig_AntipodeAgentOptions added in v0.4.84 

type MultiConfig_AntipodeAgentOptions struct {

	// the type of the datastore e.g. "redis"
	DatastoreType string `protobuf:"bytes,1,opt,name=datastoreType,proto3" json:"datastoreType,omitempty"`
	// the datastore host
	Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	// the datastore port
	Port string `protobuf:"bytes,3,opt,name=port,proto3" json:"port,omitempty"`
	// the datastore user
	User string `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	// the datastore password
	Password string `protobuf:"bytes,5,opt,name=password,proto3" json:"password,omitempty"`
	// the datastore name
	Datastore string `protobuf:"bytes,6,opt,name=datastore,proto3" json:"datastore,omitempty"`
	// the datastore queue
	Queue string `protobuf:"bytes,7,opt,name=queue,proto3" json:"queue,omitempty"`
	// contains filtered or unexported fields
}

Options for the application antipode agents, keyed by antipode agent name. If an antipode agent isn't specified in the map, default options will be used.

func (*MultiConfig_AntipodeAgentOptions) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use MultiConfig_AntipodeAgentOptions.ProtoReflect.Descriptor instead.

func (*MultiConfig_AntipodeAgentOptions) GetDatastore added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) GetDatastore() string

func (*MultiConfig_AntipodeAgentOptions) GetDatastoreType added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) GetDatastoreType() string

func (*MultiConfig_AntipodeAgentOptions) GetHost added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) GetHost() string

func (*MultiConfig_AntipodeAgentOptions) GetPassword added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) GetPassword() string

func (*MultiConfig_AntipodeAgentOptions) GetPort added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) GetPort() string

func (*MultiConfig_AntipodeAgentOptions) GetQueue added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) GetQueue() string

func (*MultiConfig_AntipodeAgentOptions) GetUser added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) GetUser() string

func (*MultiConfig_AntipodeAgentOptions) ProtoMessage added in v0.4.84 

func (*MultiConfig_AntipodeAgentOptions) ProtoMessage()

func (*MultiConfig_AntipodeAgentOptions) ProtoReflect added in v0.4.84 

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

func (*MultiConfig_AntipodeAgentOptions) Reset added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) Reset()

func (*MultiConfig_AntipodeAgentOptions) String added in v0.4.84 

func (x *MultiConfig_AntipodeAgentOptions) String() string

type MultiConfig_ListenerOptions 

type MultiConfig_ListenerOptions struct {

	// Address of the listener. The value must have the form :port or
	// host:port, or it may be the empty string, which is treated as ":0".
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

Options for the application listeners, keyed by listener name. If a listener isn't specified in the map, default options will be used.

func (*MultiConfig_ListenerOptions) Descriptor deprecated 

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

Deprecated: Use MultiConfig_ListenerOptions.ProtoReflect.Descriptor instead.

func (*MultiConfig_ListenerOptions) GetAddress 

func (x *MultiConfig_ListenerOptions) GetAddress() string

func (*MultiConfig_ListenerOptions) ProtoMessage 

func (*MultiConfig_ListenerOptions) ProtoMessage()

func (*MultiConfig_ListenerOptions) ProtoReflect 

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

func (*MultiConfig_ListenerOptions) Reset 

func (x *MultiConfig_ListenerOptions) Reset()

func (*MultiConfig_ListenerOptions) String 

func (x *MultiConfig_ListenerOptions) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.